Commit 7f49812
stream: inline unbuffered _write
PR-URL: #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>1 parent 2ab4ebc commit 7f49812
1 file changed
Lines changed: 6 additions & 1 deletion
| 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 | |
0 commit comments