Lines Matching refs:stream
48 uv_stream_t stream;
56 uv_tcp_t stream;
64 uv_pipe_t stream;
80 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf);
127 r = uv_read_start(&conn->stream, alloc_cb, read_cb);
133 r = uv_write(&conn->write_req, &conn->stream, &buf, 1, after_write);
138 static void read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) {
140 ASSERT_NOT_NULL(stream);
146 uv_close((uv_handle_t*)stream, close_cb);
202 r = uv_tcp_init(loop, (uv_tcp_t*)&p->stream);
208 (uv_tcp_t*) &p->stream,
222 p->stream.data = p;
229 r = uv_pipe_init(loop, (uv_pipe_t*)&p->stream, 0);
233 (uv_pipe_t*) &p->stream,
243 p->stream.data = p;