Class Stream<Item>

constructor

• new Stream<Item>(
      iterator: () => AsyncIterator<Item>,
      controller: AbortController,
      client?: BaseGeminiNextGenAPIClient,
  ): Stream<Item>

  Type Parameters

  • Item

  Parameters

  • iterator: () => AsyncIterator<Item>
  • controller: AbortController
  • Optionalclient: BaseGeminiNextGenAPIClient

  Returns Stream<Item>

controller

[asyncIterator]

• "[asyncIterator]"(): AsyncIterator<Item>

  Returns AsyncIterator<Item>

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(): ReadableStream

  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 ReadableStream

StaticfromReadableStream

• fromReadableStream<Item>(
      readableStream: ReadableStream,
      controller: AbortController,
      client?: BaseGeminiNextGenAPIClient,
  ): Stream<Item>

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

  Type Parameters

  • Item

  Parameters

  • readableStream: ReadableStream
  • controller: AbortController
  • Optionalclient: BaseGeminiNextGenAPIClient

  Returns Stream<Item>

StaticfromSSEResponse

• fromSSEResponse<Item>(
      response: Response,
      controller: AbortController,
      client?: BaseGeminiNextGenAPIClient,
  ): Stream<Item>

  Type Parameters

  • Item

  Parameters

  • response: Response
  • controller: AbortController
  • Optionalclient: BaseGeminiNextGenAPIClient

  Returns Stream<Item>