ReadableStream 可读流,也称为可读端,基于 Web APIs 标准 ReadableStream 进行设计。
注意:不支持直接构造
ReadableStream
对象,使用 TransformStream 构造得到。
// 使用 TransformStream 构造得到 ReadableStream 对象
const { readable } = new TransformStream();
// readable.locked
readonly locked: boolean;
标识流是否锁定。
说明:流处于锁定状态的情况有:
- 一个流最多有一个激活的
reader
,在reader
调用releaseLock()
方法前,该流均处于锁定状态。- 流处于管道传输中,会处于锁定状态,直至管道传输结束。
注意:使用下述所有方法,要求当前流处于非锁定状态,否则会抛出异常。
readable.getReader(options?: ReaderOptions): ReadableStreamDefaultReader | ReadableStreamBYOBReader;
创建一个 Reader
, 并锁定当前流,直至 Reader
调用 releaseLock() 释放锁。
参数名称 | 类型 | 必填 | 说明 |
---|---|---|---|
options | ReaderOptions | 是 | 生成 Reader 的配置项。 |
ReaderOptions
对象属性如下所示。
属性名 | 类型 | 必填 | 说明 |
---|---|---|---|
mode | string | 否 |
Reader 类型,默认值为 undefined ,取值说明如下。
创建 ReadableStreamDefaultReader 类型的
Reader 。
创建 ReadableStreamBYOBReader 类型的
Reader 。
|
readable.pipeThrough(transfromStream: TransfromStream, options?: PipeToOptions): ReadableStream;
流的管道处理。将当前可读流数据传输到参数 transfromStream
的 writable 端,并返回 transfromStream
的 readable 端。
注意:在管道传输过程中,会对当前流
writable
端进行锁定。
参数名称 | 类型 | 必填 | 说明 |
---|---|---|---|
transfromStream | TransfromStream | 是 | 当前流传输到的目标对象。 |
options | PipeToOptions | 是 | 流处理配置项。 |
流处理配置项如下所示:
属性名 | 类型 | 必填 | 说明 |
---|---|---|---|
preventClose | boolean | 否 | 取值 true 时,表示可读流的关闭,不会导致可写流关闭。 |
preventAbort | boolean | 否 | 取值 true 时,表示可读流发生错误,不会导致可写流中止。 |
preventCancel | boolean | 否 | 取值 true 时,表示可写流的错误,不会导致结束可读流。 |
signal | AbortSignal | 否 | 当 `signal` 被 abort 时,将会中止正在进行的传输。 |
readable.pipeTo(destination: WritableStream, options?: PipeToOptions): Promise<void>;
流的管道处理,将当前可读流传输到 destination
可写流。
注意:在管道传输过程中,会对当前流
destination
进行锁定。
参数名称 | 类型 | 必填 | 说明 |
---|---|---|---|
destination | WritableStream | 是 | 可写流。 |
options | PipeToOptions | 是 | 流处理配置项。 |
readable.tee(): [ReadableStream, ReadableStream];
将当前流派发出两个独立的可读流。
readable.cancel(reason?: string): Promise<string>;
结束当前流。
本页内容是否解决了您的问题?