Potentially outdated documentation
You're reading API reference for version 3.0.3. The latest stable release is 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