Lines Matching refs:highWaterMark
175 this.highWaterMark = options ?
274 // This returns true if the highWaterMark has not been hit yet,
349 // We can push more data if we are below the highWaterMark.
353 (state.length < state.highWaterMark || state.length === 0);
459 if (n > state.highWaterMark)
460 state.highWaterMark = computeNewHighWaterMark(n);
470 ((state.highWaterMark !== 0 ?
471 state.length >= state.highWaterMark :
517 // If we currently have less than the highWaterMark, then also read some.
518 if (state.length === 0 || state.length - n < state.highWaterMark) {
539 this._read(state.highWaterMark);
558 state.needReadable = state.length <= state.highWaterMark;
641 // 3. It is below the highWaterMark, so we can schedule
646 state.length <= state.highWaterMark;
668 // - Not enough data buffered (state.length < state.highWaterMark). The loop
670 // is available. If highWaterMark is 0 and we are not in the flowing mode
689 (state.length < state.highWaterMark ||
1237 return this._readableState.highWaterMark;