Function initStreamingBackpressure

lib/internal/quic/quic.js:1410–1420

(stream)

// Blob, FileHandle, etc.) do not use this -- they go through attachSource
// and are not subject to backpressure.
function initStreamingBackpressure(stream) {
  const state = getQuicStreamState(stream);
  // Only set defaults if the user hasn't already configured them
  // (e.g., via createBidirectionalStream({ highWaterMark: N })).
  if (state.highWaterMark === 0) {
    state.highWaterMark = kDefaultHighWaterMark;
  }
  if (state.writeDesiredSize === 0) {
    state.writeDesiredSize = state.highWaterMark;
  }
}

// Waits for the stream's drain callback to fire, indicating the
// outbound has capacity for more data.