nodejs
diff --git a/Collapse file
‎src/stream_base.cc‎
Copy file name to clipboardExpand all lines: src/stream_base.cc
+3-10Lines changed: 3 additions & 10 deletions b/Collapse file
‎src/stream_base.cc‎
Copy file name to clipboardExpand all lines: src/stream_base.cc
+3-10Lines changed: 3 additions & 10 deletions
diff --git a/Collapse file
‎src/stream_base.h‎
Copy file name to clipboardExpand all lines: src/stream_base.h
-1Lines changed: 0 additions & 1 deletion b/Collapse file
‎src/stream_base.h‎
Copy file name to clipboardExpand all lines: src/stream_base.h
-1Lines changed: 0 additions & 1 deletion
diff --git a/Collapse file
‎src/stream_wrap.cc‎
Copy file name to clipboardExpand all lines: src/stream_wrap.cc
-4Lines changed: 0 additions & 4 deletions b/Collapse file
‎src/stream_wrap.cc‎
Copy file name to clipboardExpand all lines: src/stream_wrap.cc
-4Lines changed: 0 additions & 4 deletions
diff --git a/Collapse file
‎src/stream_wrap.h‎
Copy file name to clipboardExpand all lines: src/stream_wrap.h
-1Lines changed: 0 additions & 1 deletion b/Collapse file
‎src/stream_wrap.h‎
Copy file name to clipboardExpand all lines: src/stream_wrap.h
-1Lines changed: 0 additions & 1 deletion
@@ -195,8 +195,7 @@ int StreamBase::Writev(const FunctionCallbackInfo<Value>& args) {
   }
 
   err = DoWrite(req_wrap, buf_list, count, nullptr);
-  if (HasWriteQueue())
-    req_wrap_obj->Set(env->async(), True(env->isolate()));
+  req_wrap_obj->Set(env->async(), True(env->isolate()));
 
   if (err)
     req_wrap->Dispose();
@@ -254,8 +253,7 @@ int StreamBase::WriteBuffer(const FunctionCallbackInfo<Value>& args) {
   }
 
   err = DoWrite(req_wrap, bufs, count, nullptr);
-  if (HasWriteQueue())
-    req_wrap_obj->Set(env->async(), True(env->isolate()));
+  req_wrap_obj->Set(env->async(), True(env->isolate()));
   req_wrap_obj->Set(env->buffer_string(), args[1]);
 
   if (err)
@@ -381,8 +379,7 @@ int StreamBase::WriteString(const FunctionCallbackInfo<Value>& args) {
         reinterpret_cast<uv_stream_t*>(send_handle));
   }
 
-  if (HasWriteQueue())
-    req_wrap_obj->Set(env->async(), True(env->isolate()));
+  req_wrap_obj->Set(env->async(), True(env->isolate()));
 
   if (err)
     req_wrap->Dispose();
@@ -476,10 +473,6 @@ int StreamResource::DoTryWrite(uv_buf_t** bufs, size_t* count) {
   return 0;
 }
 
-bool StreamResource::HasWriteQueue() {
-  return true;
-}
-
 
 const char* StreamResource::Error() const {
   return nullptr;
 
@@ -162,7 +162,6 @@ class StreamResource {
                       uv_buf_t* bufs,
                       size_t count,
                       uv_stream_t* send_handle) = 0;
-  virtual bool HasWriteQueue();
   virtual const char* Error() const;
   virtual void ClearError();
 
 
@@ -380,10 +380,6 @@ int LibuvStreamWrap::DoWrite(WriteWrap* w,
 }
 
 
-bool LibuvStreamWrap::HasWriteQueue() {
-  return stream()->write_queue_size > 0;
-}
-
 
 void LibuvStreamWrap::AfterUvWrite(uv_write_t* req, int status) {
   WriteWrap* req_wrap = WriteWrap::from_req(req);
 
@@ -55,7 +55,6 @@ class LibuvStreamWrap : public HandleWrap, public StreamBase {
               uv_buf_t* bufs,
               size_t count,
               uv_stream_t* send_handle) override;
-  bool HasWriteQueue() override;
 
   inline uv_stream_t* stream() const {
     return stream_;
Original file line number	Diff line number	Diff line change
`@@ -380,10 +380,6 @@ int LibuvStreamWrap::DoWrite(WriteWrap* w,`
`380`	`380`	`}`
`381`	`381`
`382`	`382`
`383`		`-bool LibuvStreamWrap::HasWriteQueue() {`
`384`		`- return stream()->write_queue_size > 0;`
`385`		`-}`
`386`		`-`
`387`	`383`
`388`	`384`	`void LibuvStreamWrap::AfterUvWrite(uv_write_t* req, int status) {`
`389`	`385`	`WriteWrap* req_wrap = WriteWrap::from_req(req);`