Skip to content

ReadableStream

Types

t

type t<'r> = WebAPI.FileTypes.readableStream<'r>

Record fields

Values

cancel

let cancel: (t<'r>, ~reason: JSON.t=?) => promise<unit>

Parameters

toption<Stdlib.JSON.t>

Return type

promise<unit>

fromUnderlyingSource

fromUnderlyingSource(underlyingSource<'t>, ~strategy: queuingStrategy<'t>=?)

Creates a new ReadableStream from an underlyingSource, with an optional queuing strategy.

let stream = ReadableStream.fromUnderlyingSource(myUnderlyingSource)

let streamWithStrategy =
  ReadableStream.fromUnderlyingSource(myUnderlyingSource, ~strategy=myQueuingStrategy)

Read more on MDN

let fromUnderlyingSource: (
WebAPI.FileTypes.underlyingSource<'t>,
~strategy: WebAPI.FileTypes.queuingStrategy<'t>=?,
) => t<'t>

getReader

let getReader: (
t<'r>,
~options: WebAPI.FileTypes.readableStreamGetReaderOptions=?,
) => WebAPI.FileTypes.readableStreamReader<'r>

make

make()

Creates a new empty ReadableStream.

let stream: ReadableStream.t<string> = ReadableStream.make()

Read more on MDN

let make: unit => t<'t>

Parameters

unit

Return type

t

pipeThrough

let pipeThrough: (
t<'r>,
~transform: WebAPI.FileTypes.readableWritablePair<'t, 'r>,
~options: WebAPI.FileTypes.streamPipeOptions=?,
) => t<'t>

pipeTo

let pipeTo: (
t<'r>,
~destination: WebAPI.FileTypes.writableStream<'r>,
~options: WebAPI.FileTypes.streamPipeOptions=?,
) => promise<unit>

tee

let tee: t<'r> => array<t<unit>>

Parameters

t

Return type

array<t<unit>>