Method wrapReadable

libraries/stream-extra/src/duplex.ts:70–91

(
        readable: ReadableStream<R>,
        strategy?: QueuingStrategy<R>,
    )

    }

    wrapReadable(
        readable: ReadableStream<R>,
        strategy?: QueuingStrategy<R>,
    ): WrapReadableStream<R> {
        return new WrapReadableStream<R>(
            {
                start: (controller) => {
                    this.#readableControllers.push(controller);
                    return readable;
                },
                cancel: async () => {
                    // cancel means the local peer wants to close the connection.
                    await this.close();
                },
                close: async () => {
                    // stream end means the remote peer closed the connection first.
                    await this.dispose();
                },
            },
            strategy,
        );
    }

    createWritable(stream: WritableStream<W>): WritableStream<W> {
        const writer = stream.getWriter();