Lines Matching refs:buffered
135 // When true all writes will be buffered until .uncork() call.
144 // A flag to know if we're processing previously buffered items, which
203 state.buffered = [];
210 return ArrayPrototypeSlice(this.buffered, this.bufferedIndex);
216 return this.buffered.length - this.bufferedIndex;
380 state.buffered.push({ chunk, encoding, callback });
421 // it's related to one specific write, not to the buffered
463 if (state.buffered.length > state.bufferedIndex) {
516 for (let n = state.bufferedIndex; n < state.buffered.length; ++n) {
517 const { chunk, callback } = state.buffered[n];
540 const { buffered, bufferedIndex, objectMode } = state;
541 const bufferedLength = buffered.length - bufferedIndex;
554 for (let n = i; n < buffered.length; ++n) {
555 buffered[n].callback(err);
558 // Make a copy of `buffered` if it's going to be used by `callback` above,
561 buffered : ArrayPrototypeSlice(buffered, i);
569 const { chunk, encoding, callback } = buffered[i];
570 buffered[i++] = null;
573 } while (i < buffered.length && !state.writing);
575 if (i === buffered.length) {
578 buffered.splice(0, i);
659 state.buffered.length === 0 &&
892 (state.bufferedIndex < state.buffered.length ||