Method write

lib/internal/quic/quic.js:2172–2194

(chunk, options = kEmptyObject)

    }

    async function write(chunk, options = kEmptyObject) {
      validateObject(options, 'options');
      const { signal } = options;
      if (signal !== undefined) {
        validateAbortSignal(signal, 'options.signal');
        signal.throwIfAborted();
      }
      if (errored) throw error;
      if (closed || stream.#inner.state.writeEnded) {
        throw new ERR_INVALID_STATE('Writer is closed');
      }
      // If a drain is already pending, another operation is waiting
      // for capacity. Under strict policy, reject immediately.
      // Later, if we add support for other backpressure policies,
      // we could instead await the existing drain before proceeding.
      if (drainWakeup != null) {
        throw new ERR_INVALID_STATE('Stream write buffer is full');
      }

      if (!writeSync(chunk)) {
        throw new ERR_INVALID_STATE('Stream write buffer is full');
      }
    }

    function writevSync(chunks) {
      if (closed || errored || stream.#inner.state.writeEnded || drainWakeup != null) {