Function consumeSyncSource

lib/internal/quic/quic.js:1481–1505

(handle, stream, source)

}

async function consumeSyncSource(handle, stream, source) {
  handle.initStreamingSource();
  initStreamingBackpressure(stream);
  // Normalize to Iterable<Uint8Array[]>. Manually iterate so we can
  // pause between next() calls when backpressure hits.
  const normalized = streamFromSync(source);
  const iter = normalized[SymbolIterator]();
  try {
    while (true) {
      if (stream.destroyed) return;
      const { value: batch, done } = iter.next();
      if (done) break;
      if (await writeBatchWithDrain(handle, stream, batch)) return;
    }
    handle.endWrite();
  } catch (err) {
    if (!stream.destroyed) {
      stream.destroy(err);
    } else {
      // If the stream is already destroyed, rethrow the error to avoid
      // silently swallowing it. Tho in practice this shouldn't happen.
      throw err;
    }
  }
}

function isAsyncIterable(obj) {
  return obj != null && typeof obj[SymbolAsyncIterator] === 'function';