stream library

Functions

combineLatest2<A, B, C>(Stream<A> a, Stream<B> b, C mapper(A, B)) → Stream<C>

combineLatest2Tuple<A, B>(Stream<A> a, Stream<B> b) → Stream<(A, B)>

fromIO<A>(IO<A> io) → Stream<A>

fromTask<A>(Task<A> task) → Stream<A>