Lines Matching defs:sink
23 StreamBase* sink,
28 CHECK_NOT_NULL(sink);
32 sink->PushStreamListener(&writable_listener_);
34 uses_wants_write_ = sink->HasWantsWrite();
45 StreamBase* StreamPipe::sink() {
53 // Note that we possibly cannot use virtual methods on `source` and `sink`
63 sink()->RemoveStreamListener(&writable_listener_);
123 // Cache `sink()` here because the previous listener might do things
125 StreamBase* sink = pipe->sink();
132 sink->Shutdown();
145 StreamWriteResult res = sink()->Write(&buffer, 1);
177 pipe->sink()->Shutdown();
244 StreamBase* sink,
246 std::unique_ptr<StreamPipe> stream_pipe(new StreamPipe(source, sink, obj));
248 // Set up links between this object and the source/sink objects.
262 if (obj->Set(env->context(), env->sink_string(), sink->GetObject())
266 if (sink->GetObject()
280 StreamBase* sink = StreamBase::FromObject(args[1].As<Object>());
282 if (StreamPipe::New(source, sink, args.This()).IsNothing()) return;