Function writeBatchWithDrain

lib/internal/quic/quic.js:1440–1459

(handle, stream, batch)

// is larger -- the C++ side buffers the data and writeDesiredSize
// drops toward 0, letting the normal drain mechanism take over.
async function writeBatchWithDrain(handle, stream, batch) {
  const state = getQuicStreamState(stream);

  if (state.writeDesiredSize === 0) {
    await waitForDrain(stream);
    if (stream.destroyed) return true;
  }

  // Write the batch. The return value is the total queued byte count
  // on success, or undefined on failure (e.g., DataQueue append
  // rejected). Guard against silent data loss.
  const result = handle.write(batch);
  if (result === undefined) {
    if (!stream.destroyed) {
      stream.destroy(new ERR_INVALID_STATE('Stream write failed'));
    }
    return true;
  }
  return false;
}

async function consumeAsyncSource(handle, stream, source) {
  handle.initStreamingSource();