WIP: added Stream/Connection

This commit is contained in:
Michele Caini 2016-06-20 13:54:00 +02:00
parent 7d81366c50
commit fc83897d0b
4 changed files with 29 additions and 4 deletions

View File

@ -1,5 +1,6 @@
#include "uvw/check.hpp"
#include "uvw/error.hpp"
#include "uvw/loop.hpp"
#include "uvw/stream.hpp"
#include "uvw/tcp.hpp"
#include "uvw/timer.hpp"

View File

@ -26,7 +26,7 @@ protected:
public:
using Callback = std::function<void(UVWError)>;
~Resource() { static_assert(std::is_base_of<Resource<T>, T>::value, "!"); }
virtual ~Resource() = 0;
Resource(const Resource &) = delete;
Resource(Resource &&) = delete;
@ -51,5 +51,10 @@ private:
Callback callback;
};
template<typename T>
Resource<T>::~Resource() {
static_assert(std::is_base_of<Resource<T>, T>::value, "!");
}
}

19
src/uvw/stream.hpp Normal file
View File

@ -0,0 +1,19 @@
#pragma once
namespace uvw {
template<class T>
class Connection: public Resource<T> {
using Resource<T>::Resource;
};
template<class T>
class Stream: public Connection<T> {
using Connection<T>::Connection;
};
}

View File

@ -5,14 +5,14 @@
#include <chrono>
#include <ratio>
#include <uv.h>
#include "resource.hpp"
#include "stream.hpp"
#include "error.hpp"
namespace uvw {
class Tcp final: public Resource<Tcp> {
class Tcp final: public Stream<Tcp> {
static void protoConnect(uv_connect_t* req, int status) {
auto handle = req->handle;
delete req;
@ -25,7 +25,7 @@ public:
enum { IPv4, IPv6 };
explicit Tcp(uv_loop_t *loop): Resource{&handle} {
explicit Tcp(uv_loop_t *loop): Stream<Tcp>{&handle} {
uv_tcp_init(loop, &handle);
}