Effection Logo

function stream

thefrontside/effection

function stream<T, R>(iterable: AsyncIterable<T, R>): Stream<T, R>

Convert any AsyncIterable into an Effection Stream.

This allows you to consume any AsyncIterable as a Stream.

Type Parameters

T

R

Parameters

iterable: AsyncIterable<T, R>

  • the async iterable to convert

Return Type

Stream<T, R>

a stream that will produce each item of iterable