};
-function writeAfterEnd(stream, state, cb) {
+function writeAfterEnd(stream, cb) {
var er = new Error('write after end');
// TODO: defer error events consistently everywhere, not just the cb
stream.emit('error', er);
cb = nop;
if (state.ended)
- writeAfterEnd(this, state, cb);
+ writeAfterEnd(this, cb);
else if (validChunk(this, state, chunk, cb)) {
state.pendingcb++;
ret = writeOrBuffer(this, state, chunk, encoding, cb);
onwriteError(stream, state, sync, er, cb);
else {
// Check if we're actually ready to finish, but don't emit yet
- var finished = needFinish(stream, state);
+ var finished = needFinish(state);
if (!finished &&
!state.corked &&
};
-function needFinish(stream, state) {
+function needFinish(state) {
return (state.ending &&
state.length === 0 &&
state.bufferedRequest === null &&
}
function finishMaybe(stream, state) {
- var need = needFinish(stream, state);
+ var need = needFinish(state);
if (need) {
if (state.pendingcb === 0) {
prefinish(stream, state);
// NOTE: These type checking functions intentionally don't use `instanceof`
// because it is fragile and can be easily faked with `Object.create()`.
-const isArray = exports.isArray = Array.isArray;
+exports.isArray = Array.isArray;
function isBoolean(arg) {
return typeof arg === 'boolean';