luo980/uvw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added a couple of TODO

Browse Source
This commit is contained in:
Michele Caini 2016-07-14 22:50:17 +02:00
parent 78e6de086f
commit becef55848
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/uvw/stream.hpp
View File

@ -37,6 +37,7 @@ class Stream: public Handle<T> {
}
static void writeCallback(uv_write_t *req, int status) {
// TODO migrate to Request (see request.hpp for further details)
T &ref = *(static_cast<T*>(req->handle->data));
if(status) { ref.publish(ErrorEvent{status}); }
else { ref.publish(WriteEvent{}); }
@ -85,6 +86,7 @@ public:
void write(char *data, ssize_t length) {
uv_buf_t bufs[] = { uv_buf_init(data, length) };
// TODO migrate to Request (see request.hpp for further details)
uv_write_t *req = new uv_write_t;
auto err = uv_write(req, this->template get<uv_stream_t>(), bufs, 1, &Stream<T>::writeCallback);