Lines Matching refs:highWaterMark

71518     return this._writableState.highWaterMark;
71743 …this.highWaterMark = getHighWaterMark(this, options, 'readableHighWaterMark', isDuplex); // A link…
71914   return !state.ended && (state.length < state.highWaterMark || state.length === 0);
72002   if (n > state.highWaterMark) state.highWaterMark = computeNewHighWaterMark(n);
72023 …if (n === 0 && state.needReadable && ((state.highWaterMark !== 0 ? state.length >= state.highWater…
72061   if (state.length === 0 || state.length - n < state.highWaterMark) {
72078     this._read(state.highWaterMark);
72090     state.needReadable = state.length <= state.highWaterMark;
72170   state.needReadable = !state.flowing && !state.ended && state.length <= state.highWaterMark;
72211 …while (!state.reading && !state.ended && (state.length < state.highWaterMark || state.flowing && s…
72644     return this._readableState.highWaterMark;
72843   if (rs.needReadable || rs.length < rs.highWaterMark) {
72844     this._read(rs.highWaterMark);
72914 …(ts.needTransform || rs.needReadable || rs.length < rs.highWaterMark) this._read(rs.highWaterMark);
73073 …this.highWaterMark = getHighWaterMark(this, options, 'writableHighWaterMark', isDuplex); // if _fi…
73311     return this._writableState.highWaterMark;
73330 …var ret = state.length < state.highWaterMark; // we must ensure that previous needDrain will not b…
74477 …return options.highWaterMark != null ? options.highWaterMark : isDuplex ? options[duplexKey] : nul…
79079     return this._writableState.highWaterMark;
79299   var hwm = options.highWaterMark;
79302 …= 0) this.highWaterMark = hwm;else if (isDuplex && (readableHwm || readableHwm === 0)) this.highWa…
79304 …this.highWaterMark = Math.floor(this.highWaterMark); // A linked list is used to store data chunks…
79492 …return !state.ended && (state.needReadable || state.length < state.highWaterMark || state.length =…
79540   if (n > state.highWaterMark) state.highWaterMark = computeNewHighWaterMark(n);
79561   if (n === 0 && state.needReadable && (state.length >= state.highWaterMark || state.ended)) {
79599   if (state.length === 0 || state.length - n < state.highWaterMark) {
79616     this._read(state.highWaterMark);
79699   while (!state.reading && !state.flowing && !state.ended && state.length < state.highWaterMark) {
80069     return this._readableState.highWaterMark;
80308   if (rs.needReadable || rs.length < rs.highWaterMark) {
80309     this._read(rs.highWaterMark);
80379 …(ts.needTransform || rs.needReadable || rs.length < rs.highWaterMark) this._read(rs.highWaterMark);
80546   var hwm = options.highWaterMark;
80549 …= 0) this.highWaterMark = hwm;else if (isDuplex && (writableHwm || writableHwm === 0)) this.highWa…
80551   this.highWaterMark = Math.floor(this.highWaterMark); // if _final has been called
80777     return this._writableState.highWaterMark;
80796 …var ret = state.length < state.highWaterMark; // we must ensure that previous needDrain will not b…