Lines Matching defs:source
22 StreamPipe::StreamPipe(StreamBase* source,
25 : AsyncWrap(source->stream_env(), obj, AsyncWrap::PROVIDER_STREAMPIPE) {
29 CHECK_NOT_NULL(source);
31 source->PushStreamListener(&readable_listener_);
41 StreamBase* StreamPipe::source() {
53 // Note that we possibly cannot use virtual methods on `source` and `sink`
57 source()->ReadStop();
61 source()->RemoveStreamListener(&readable_listener_);
152 if (source() != nullptr)
153 source()->ReadStop();
229 pipe->source()->ReadStart();
243 Maybe<StreamPipe*> StreamPipe::New(StreamBase* source,
246 std::unique_ptr<StreamPipe> stream_pipe(new StreamPipe(source, sink, obj));
248 // Set up links between this object and the source/sink objects.
252 Environment* env = source->stream_env();
253 if (obj->Set(env->context(), env->source_string(), source->GetObject())
257 if (source->GetObject()
279 StreamBase* source = StreamBase::FromObject(args[0].As<Object>());
282 if (StreamPipe::New(source, sink, args.This()).IsNothing()) return;