Method [SymbolAsyncIterator]

lib/internal/quic/quic.js:1638–1675

* Returns an AsyncIterator that yields Uint8Array[] batches of * incoming data. Only one iterator can be obtained per stream. * Non-readable streams return an immediately-finished iterator. * @yields {Uint8Array[]}

()

   * @yields {Uint8Array[]}
   */
  async *[SymbolAsyncIterator]() {
    assertIsQuicStream(this);
    const inner = this.#inner;
    if (inner.iteratorLocked) {
      throw new ERR_INVALID_STATE('Stream is already being read');
    }
    inner.iteratorLocked = true;

    inner.reader ??= this.#handle?.getReader();
    // Non-readable stream (outbound-only unidirectional, or closed)
    if (!inner.reader) return;

    yield* createBlobReaderIterable(inner.reader, {
      getReadError: () => {
        // The read side ends for one of three reasons:
        //   * Clean FIN received from the peer (state.finReceived
        //     === true). The iterator stops without calling this;
        //     fall through to the generic state error if it does.
        //   * Peer sent us a RESET_STREAM. The C++ side records the
        //     code in state.resetCode regardless of whether the JS
        //     onreset handler was attached. state.finReceived stays
        //     false because no FIN was seen.
        //   * We aborted locally via stream.resetStream() or
        //     stream.stopSending(). Both paths run EndReadable in
        //     C++, setting state.readEnded without setting
        //     state.finReceived. There is no peer code to surface.
        if (inner.state.readEnded && !inner.state.finReceived) {
          const peerResetCode = inner.state.resetCode;
          if (peerResetCode !== undefined && peerResetCode > 0n) {
            return new ERR_QUIC_STREAM_RESET(Number(peerResetCode));
          }
          return new ERR_QUIC_STREAM_ABORTED(
            'Stream aborted before FIN was received');
        }
        return new ERR_INVALID_STATE('The stream is not readable');
      },
    });
  }

  /**
   * True if the stream is still pending (i.e. it has not yet been opened