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

refinements

Browse Source
This commit is contained in:
Michele Caini 2016-07-04 17:14:49 +02:00
parent e625b0bd12
commit cd7584eb5f
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/uvw/stream.hpp
View File

@ -82,8 +82,8 @@ public:
this->invoke(&uv_read_stop, this->template get<uv_stream_t>());
}
void write(std::unique_ptr<char[]> data, ssize_t length) {
uv_buf_t bufs[] = { uv_buf_init(data.get(), length) };
void write(char *data, ssize_t length) {
uv_buf_t bufs[] = { uv_buf_init(data, length) };
uv_write_t *req = new uv_write_t;
auto err = uv_write(req, this->template get<uv_stream_t>(), bufs, 1, &Stream<T>::writeCallback);
@ -94,8 +94,12 @@ public:
}
}
int tryWrite(std::unique_ptr<char[]> data, ssize_t length) noexcept {
uv_buf_t bufs[] = { uv_buf_init(data.get(), length) };
void write(std::unique_ptr<char[]> data, ssize_t length) {
write(data.get(), length);
}
int tryWrite(char *data, ssize_t length) noexcept {
uv_buf_t bufs[] = { uv_buf_init(data, length) };
auto bw = uv_try_write(this->template get<uv_stream_t>(), bufs, 1);
if(bw < 0) {
@ -106,6 +110,10 @@ public:
return bw;
}
int tryWrite(std::unique_ptr<char[]> data, ssize_t length) noexcept {
return tryWrite(data.get(), length);
}
bool readable() const noexcept {
return (uv_is_readable(this->template get<uv_stream_t>()) == 1);
}