(stream, state, writev, len, chunk, encoding, cb)
| 585 | } |
| 586 | |
| 587 | function doWrite(stream, state, writev, len, chunk, encoding, cb) { |
| 588 | state.writelen = len; |
| 589 | if (cb !== nop) { |
| 590 | state.writecb = cb; |
| 591 | } |
| 592 | state[kState] |= kWriting | kSync | kExpectWriteCb; |
| 593 | if ((state[kState] & kDestroyed) !== 0) |
| 594 | state.onwrite(new ERR_STREAM_DESTROYED('write')); |
| 595 | else if (writev) |
| 596 | stream._writev(chunk, state.onwrite); |
| 597 | else |
| 598 | stream._write(chunk, encoding, state.onwrite); |
| 599 | state[kState] &= ~kSync; |
| 600 | } |
| 601 | |
| 602 | function onwriteError(stream, state, er, cb) { |
| 603 | --state.pendingcb; |
no test coverage detected
searching dependent graphs…