Method #createStream

lib/internal/quic/quic.js:3237–3312

* @param {number} direction * @param {OpenStreamOptions} options * @returns {QuicStream}

(direction, options = kEmptyObject)

   * @returns {QuicStream}
   */
  async #createStream(direction, options = kEmptyObject) {
    const inner = this.#inner;
    if (this.#isClosedOrClosing) {
      throw new ERR_INVALID_STATE('Session is closed. New streams cannot be opened.');
    }
    const dir = direction === kStreamDirectionBidirectional ? 'bidi' : 'uni';
    if (inner.state.isStreamOpenAllowed) {
      debug(`opening new pending ${dir} stream`);
    } else {
      debug(`opening new ${dir} stream`);
    }

    validateObject(options, 'options');
    const {
      body,
      priority = 'default',
      incremental = false,
      highWaterMark = kDefaultHighWaterMark,
      headers,
      onheaders,
      ontrailers,
      oninfo,
      onwanttrailers,
    } = options;

    validateOneOf(priority, 'options.priority', ['default', 'low', 'high']);
    validateBoolean(incremental, 'options.incremental');

    const validatedBody = validateBody(body);

    const handle = this.#handle.openStream(direction, validatedBody);
    if (handle === undefined) {
      throw new ERR_QUIC_OPEN_STREAM_FAILED();
    }

    if (inner.state.isPrioritySupported) {
      const urgency = priority === 'high' ? 0 : priority === 'low' ? 7 : 3;
      handle.setPriority((urgency << 1) | (incremental ? 1 : 0));
    }

    const stream = new QuicStream(
      kPrivateConstructor, handle, this, direction, true /* isLocal */);
    inner.streams.add(stream);
    if (typeof this.#inner.onerror === 'function') {
      markPromiseAsHandled(stream.closed);
    }

    // If the body was a FileHandle, store it on the stream so it is
    // closed automatically when the stream finishes.
    if (FileHandle.isFileHandle(body)) {
      stream[kAttachFileHandle](body);
    }

    // Set the high water mark for backpressure.
    stream.highWaterMark = highWaterMark;

    // Set stream callbacks before sending headers to avoid missing events.
    if (onheaders) stream.onheaders = onheaders;