stream: inline unbuffered _write

ronag · ronag · commit fd10be4b5456 · 2020-04-18T21:10:40.000+02:00
PR-URL: nodejs#32886 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Zeyu Yang <himself65@outlook.com> Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de>
diff --git a/lib/_stream_writable.js b/lib/_stream_writable.js
@@ -364,7 +364,12 @@ function writeOrBuffer(stream, state, chunk, encoding, cb) {
     }
     state.bufferedRequestCount += 1;
   } else {
-    doWrite(stream, state, false, len, chunk, encoding, cb);
+    state.writelen = len;
+    state.writecb = cb;
+    state.writing = true;
+    state.sync = true;
+    stream._write(chunk, encoding, state.onwrite);
+    state.sync = false;
   }
 
   // Return false if errored or destroyed in order to break

Original file line number	Diff line number	Diff line change
`@@ -364,7 +364,12 @@ function writeOrBuffer(stream, state, chunk, encoding, cb) {`
`364`	`364`	`}`
`365`	`365`	`state.bufferedRequestCount += 1;`
`366`	`366`	`} else {`
`367`		`- doWrite(stream, state, false, len, chunk, encoding, cb);`
	`367`	`+ state.writelen = len;`
	`368`	`+ state.writecb = cb;`
	`369`	`+ state.writing = true;`
	`370`	`+ state.sync = true;`
	`371`	`+ stream._write(chunk, encoding, state.onwrite);`
	`372`	`+ state.sync = false;`
`368`	`373`	`}`
`369`	`374`
`370`	`375`	`// Return false if errored or destroyed in order to break`