Searched refs:StreamPipe (Results 1 – 7 of 7) sorted by relevance
22 StreamPipe::StreamPipe(StreamBase* source, in StreamPipe() function in node::StreamPipe37 StreamPipe::~StreamPipe() { in ~StreamPipe()41 StreamBase* StreamPipe::source() { in source()45 StreamBase* StreamPipe::sink() { in sink()49 void StreamPipe::Unpipe(bool is_in_deletion) { in Unpipe()70 BaseObjectPtr<StreamPipe> strong_ref{this}; in Unpipe()108 uv_buf_t StreamPipe::ReadableListener::OnStreamAlloc(size_t suggested_size) { in OnStreamAlloc()109 StreamPipe* pipe = ContainerOf(&StreamPipe::readable_listener_, this); in OnStreamAlloc()115 void StreamPipe::ReadableListener::OnStreamRead(ssize_t nread, in OnStreamRead()117 StreamPipe* pipe = ContainerOf(&StreamPipe::readable_listener_, this); in OnStreamRead()[all …]
10 class StreamPipe : public AsyncWrap {12 ~StreamPipe() override;16 static v8::Maybe<StreamPipe*> New(StreamBase* source,26 SET_MEMORY_INFO_NAME(StreamPipe)27 SET_SELF_SIZE(StreamPipe)30 StreamPipe(StreamBase* source, StreamBase* sink, v8::Local<v8::Object> obj);
187 const { StreamPipe } = internalBinding('stream_pipe');2520 const pipe = new StreamPipe(handle, self[kHandle]);
729 …ttps://github.com/nodejs/node/commit/33d6a3fcb7)] - **src**: clean up `StreamPipe` in destructor (…741 …de/commit/3abdcfc813)] - **src**: remove unimplemented method in class StreamPipe (gengjiawen) [#2…1028 * \[[`b779c072d0`](https://github.com/nodejs/node/commit/b779c072d0)] - **src**: make `StreamPipe::…
760 * \[[`f62967c827`](https://github.com/nodejs/node/commit/f62967c827)] - **src**: enable `StreamPipe…
3341 …node/commit/5e65c1f3da)] - **src**: convey potential exceptions during StreamPipe construction (Da…
2730 * \[[`0b327bd81d`](https://github.com/nodejs/node/commit/0b327bd81d)] - **src**: enable `StreamPipe…