(stream, er)
| 25320 | } |
| 25321 | |
| 25322 | function onwrite(stream, er) { |
| 25323 | var state = stream._writableState; |
| 25324 | var sync = state.sync; |
| 25325 | var cb = state.writecb; |
| 25326 | |
| 25327 | onwriteStateUpdate(state); |
| 25328 | |
| 25329 | if (er) onwriteError(stream, state, sync, er, cb);else { |
| 25330 | // Check if we're actually ready to finish, but don't emit yet |
| 25331 | var finished = needFinish(state); |
| 25332 | |
| 25333 | if (!finished && !state.corked && !state.bufferProcessing && state.bufferedRequest) { |
| 25334 | clearBuffer(stream, state); |
| 25335 | } |
| 25336 | |
| 25337 | if (sync) { |
| 25338 | /*<replacement>*/ |
| 25339 | asyncWrite(afterWrite, stream, state, finished, cb); |
| 25340 | /*</replacement>*/ |
| 25341 | } else { |
| 25342 | afterWrite(stream, state, finished, cb); |
| 25343 | } |
| 25344 | } |
| 25345 | } |
| 25346 | |
| 25347 | function afterWrite(stream, state, finished, cb) { |
| 25348 | if (!finished) onwriteDrain(stream, state); |
no test coverage detected