Version 3.0.3 is behind the current release: jump to latest version (3.1.0).
function subscribe
thefrontside/effectionfunction subscribe<T, R>(iter: AsyncIterator<T, R>): Subscription<T, R>
Convert any AsyncIterator into an effection Subscription
This allows you to consume any AsyncIterator as a Subscription.
Type Parameters
T
R
Parameters
iter: AsyncIterator<T, R>
- the iterator to convert
Return Type
Subscription<T, R>
a subscription that will produce each item of iter