: AsyncWrap(env, obj, AsyncWrap::PROVIDER_JSSTREAM),

StreamBase(env) {

MakeWeak();

StreamBase::AttachToObject(obj);

HandleScope scope(env()->isolate());

Context::Scope context_scope(env()->context());

TryCatchScope try_catch(env());

Local<Value> value;

if (!MakeCallback(env()->isclosing_string(), 0, nullptr).ToLocal(&value)) {

if (try_catch.HasCaught() && !try_catch.HasTerminated())

errors::TriggerUncaughtException(env()->isolate(), try_catch);

return true;

}

return value->IsTrue();

HandleScope scope(env()->isolate());

Context::Scope context_scope(env()->context());

TryCatchScope try_catch(env());

Local<Value> value;

int value_int = UV_EPROTO;

if (!MakeCallback(env()->onreadstart_string(), 0, nullptr).ToLocal(&value) ||

!value->Int32Value(env()->context()).To(&value_int)) {

if (try_catch.HasCaught() && !try_catch.HasTerminated())

errors::TriggerUncaughtException(env()->isolate(), try_catch);

}

return value_int;

HandleScope scope(env()->isolate());

Context::Scope context_scope(env()->context());

TryCatchScope try_catch(env());

Local<Value> value;

int value_int = UV_EPROTO;

if (!MakeCallback(env()->onreadstop_string(), 0, nullptr).ToLocal(&value) ||

!value->Int32Value(env()->context()).To(&value_int)) {

if (try_catch.HasCaught() && !try_catch.HasTerminated())

errors::TriggerUncaughtException(env()->isolate(), try_catch);

}

return value_int;

HandleScope scope(env()->isolate());

Context::Scope context_scope(env()->context());

Local<Value> argv[] = {

req_wrap->object()

};

TryCatchScope try_catch(env());

Local<Value> value;

int value_int = UV_EPROTO;

if (!MakeCallback(env()->onshutdown_string(),

arraysize(argv),

argv).ToLocal(&value) ||

!value->Int32Value(env()->context()).To(&value_int)) {

if (try_catch.HasCaught() && !try_catch.HasTerminated())

errors::TriggerUncaughtException(env()->isolate(), try_catch);

}

return value_int;

uv_buf_t* bufs,

size_t count,

uv_stream_t* send_handle) {

CHECK_NULL(send_handle);

HandleScope scope(env()->isolate());

Context::Scope context_scope(env()->context());

MaybeStackBuffer<Local<Value>, 16> bufs_arr(count);

for (size_t i = 0; i < count; i++) {

bufs_arr[i] =

Buffer::Copy(env(), bufs[i].base, bufs[i].len).ToLocalChecked();

}

Local<Value> argv[] = {

w->object(),

Array::New(env()->isolate(), bufs_arr.out(), count)

};

TryCatchScope try_catch(env());

Local<Value> value;

int value_int = UV_EPROTO;

if (!MakeCallback(env()->onwrite_string(),

arraysize(argv),

argv).ToLocal(&value) ||

!value->Int32Value(env()->context()).To(&value_int)) {

if (try_catch.HasCaught() && !try_catch.HasTerminated())

errors::TriggerUncaughtException(env()->isolate(), try_catch);

}

return value_int;

// This constructor should not be exposed to public javascript.

// Therefore we assert that we are not trying to call this as a

// normal function.

CHECK(args.IsConstructCall());

Environment* env = Environment::GetCurrent(args);

new JSStream(env, args.This());

CHECK(args[0]->IsObject());

Wrap* w = static_cast<Wrap*>(StreamReq::FromObject(args[0].As<Object>()));

CHECK(args[1]->IsInt32());

w->Done(args[1].As<Int32>()->Value());

JSStream* wrap;

ASSIGN_OR_RETURN_UNWRAP(&wrap, args.Holder());

ArrayBufferViewContents<char> buffer(args[0]);

const char* data = buffer.data();

int len = buffer.length();

// Repeatedly ask the stream's owner for memory, copy the data that we

// just read from JS into those buffers and emit them as reads.

while (len != 0) {

uv_buf_t buf = wrap->EmitAlloc(len);

ssize_t avail = len;

if (static_cast<ssize_t>(buf.len) < avail)

avail = buf.len;

memcpy(buf.base, data, avail);

data += avail;

len -= static_cast<int>(avail);

wrap->EmitRead(avail, buf);

}

JSStream* wrap;

ASSIGN_OR_RETURN_UNWRAP(&wrap, args.Holder());

wrap->EmitRead(UV_EOF);

Local<Value> unused,

Local<Context> context,

void* priv) {

Environment* env = Environment::GetCurrent(context);

Local<FunctionTemplate> t = env->NewFunctionTemplate(New);

t->InstanceTemplate()

->SetInternalFieldCount(StreamBase::kInternalFieldCount);

t->Inherit(AsyncWrap::GetConstructorTemplate(env));

env->SetProtoMethod(t, "finishWrite", Finish<WriteWrap>);

env->SetProtoMethod(t, "finishShutdown", Finish<ShutdownWrap>);

env->SetProtoMethod(t, "readBuffer", ReadBuffer);

env->SetProtoMethod(t, "emitEOF", EmitEOF);

StreamBase::AddMethods(env, t);

env->SetConstructorFunction(target, "JSStream", t);