Lines Matching refs:finished

72723       if (!wState || wState.autoDestroy && wState.finished) {
73083   this.finished = false; // has it been destroyed
73406     var finished = needFinish(state) || stream.destroyed;
73408     if (!finished && !state.corked && !state.bufferProcessing && state.bufferedRequest) {
73413       process.nextTick(afterWrite, stream, state, finished, cb);
73415       afterWrite(stream, state, finished, cb);
73420 function afterWrite(stream, state, finished, cb) {
73421   if (!finished) onwriteDrain(stream, state);
73540 …return state.ending && state.length === 0 && state.bufferedRequest === null && !state.finished && …
73577       state.finished = true;
73600     if (state.finished) process.nextTick(cb);else stream.once('finish', cb);
73676 var finished = require('./end-of-stream');
73845   finished(stream, function (err) {
74231     this._writableState.finished = false;
74297   var writableEnded = stream._writableState && stream._writableState.finished;
74515 exports.finished = require('./lib/internal/streams/end-of-stream.js');
80561   this.finished = false; // has it been destroyed
80751 …if (!state.writing && !state.corked && !state.finished && !state.bufferProcessing && state.buffere…
80871     var finished = needFinish(state);
80873     if (!finished && !state.corked && !state.bufferProcessing && state.bufferedRequest) {
80879       asyncWrite(afterWrite, stream, state, finished, cb);
80882       afterWrite(stream, state, finished, cb);
80887 function afterWrite(stream, state, finished, cb) {
80888   if (!finished) onwriteDrain(stream, state);
80992   if (!state.ending && !state.finished) endWritable(this, state, cb);
80996 …return state.ending && state.length === 0 && state.bufferedRequest === null && !state.finished && …
81033       state.finished = true;
81046     if (state.finished) pna.nextTick(cb);else stream.once('finish', cb);
81263     this._writableState.finished = false;