Version 3.0.3 is behind the current release: jump to latest version (3.1.0).
function stream
thefrontside/effectionfunction 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