Class Stream<Item>

constructor

• new Stream<Item>(iterator, controller): Stream<Item>

• Type Parameters

  • Item

  Parameters

  • iterator: (() => AsyncIterator<Item, any, undefined>)

    • • (): AsyncIterator<Item, any, undefined>

      • Returns AsyncIterator<Item, any, undefined>

  • controller: AbortController

  Returns Stream<Item>

controller

[asyncIterator]

• [asyncIterator](): AsyncIterator<Item, any, undefined>

• Returns AsyncIterator<Item, any, undefined>

tee

• tee(): [Stream<Item>, Stream<Item>]

• Splits the stream into two streams which can be independently read from at different speeds.

  Returns [Stream<Item>, Stream<Item>]

toReadableStream

• toReadableStream(): never

• Converts this stream to a newline-separated ReadableStream of JSON stringified values in the stream which can be turned back into a Stream with Stream.fromReadableStream().

  Returns never

Static fromReadableStream

• fromReadableStream<Item>(readableStream, controller): Stream<Item>

• Generates a Stream from a newline-separated ReadableStream where each item is a JSON value.

  Type Parameters

  • Item

  Parameters

  • readableStream: never

  • controller: AbortController

  Returns Stream<Item>

Static fromSSEResponse

• fromSSEResponse<Item>(response, controller): Stream<Item>

• Type Parameters

  • Item

  Parameters

  • response: Response

  • controller: AbortController

  Returns Stream<Item>