commit
9aec261dc4
@ -1,5 +1,6 @@
|
|||||||
#include "uvw/check.hpp"
|
#include "uvw/check.hpp"
|
||||||
#include "uvw/error.hpp"
|
#include "uvw/error.hpp"
|
||||||
#include "uvw/loop.hpp"
|
#include "uvw/loop.hpp"
|
||||||
|
#include "uvw/stream.hpp"
|
||||||
#include "uvw/tcp.hpp"
|
#include "uvw/tcp.hpp"
|
||||||
#include "uvw/timer.hpp"
|
#include "uvw/timer.hpp"
|
||||||
|
|||||||
@ -26,7 +26,7 @@ protected:
|
|||||||
public:
|
public:
|
||||||
using Callback = std::function<void(UVWError)>;
|
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(const Resource &) = delete;
|
||||||
Resource(Resource &&) = delete;
|
Resource(Resource &&) = delete;
|
||||||
@ -51,5 +51,10 @@ private:
|
|||||||
Callback callback;
|
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
19
src/uvw/stream.hpp
Normal 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;
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
@ -5,14 +5,14 @@
|
|||||||
#include <chrono>
|
#include <chrono>
|
||||||
#include <ratio>
|
#include <ratio>
|
||||||
#include <uv.h>
|
#include <uv.h>
|
||||||
#include "resource.hpp"
|
#include "stream.hpp"
|
||||||
#include "error.hpp"
|
#include "error.hpp"
|
||||||
|
|
||||||
|
|
||||||
namespace uvw {
|
namespace uvw {
|
||||||
|
|
||||||
|
|
||||||
class Tcp final: public Resource<Tcp> {
|
class Tcp final: public Stream<Tcp> {
|
||||||
static void protoConnect(uv_connect_t* req, int status) {
|
static void protoConnect(uv_connect_t* req, int status) {
|
||||||
auto handle = req->handle;
|
auto handle = req->handle;
|
||||||
delete req;
|
delete req;
|
||||||
@ -25,7 +25,7 @@ public:
|
|||||||
|
|
||||||
enum { IPv4, IPv6 };
|
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);
|
uv_tcp_init(loop, &handle);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user