(stream, state, er, cb)
| 600 | } |
| 601 | |
| 602 | function onwriteError(stream, state, er, cb) { |
| 603 | --state.pendingcb; |
| 604 | |
| 605 | cb(er); |
| 606 | // Ensure callbacks are invoked even when autoDestroy is |
| 607 | // not enabled. Passing `er` here doesn't make sense since |
| 608 | // it's related to one specific write, not to the buffered |
| 609 | // writes. |
| 610 | errorBuffer(state); |
| 611 | // This can emit error, but error must always follow cb. |
| 612 | errorOrDestroy(stream, er); |
| 613 | } |
| 614 | |
| 615 | function onwrite(stream, er) { |
| 616 | const state = stream._writableState; |
no test coverage detected
searching dependent graphs…