Contents
- SourceExtensions
- As <A> (this K<Source, A> ma)
- AsSource <A> (this Channel<A> items)
- AsSource <A> (this IEnumerable<A> items)
- AsSource <A> (this IAsyncEnumerable<A> items)
- AsSource <A> (this IObservable<A> items)
- Iter <A> (this K<Source, A> ma)
- Iter <M, A> (this K<Source, A> ma)
- Last <A> (this K<Source, A> ma)
- Last <M, A> (this K<Source, A> ma)
- Collect <A> (this K<Source, A> ma)
- Collect <M, A> (this K<Source, A> ma)
class SourceExtensions Source #
Methods
method IO<Unit> Iter <A> (this K<Source, A> ma) Source #
Force iteration of the stream, yielding a unit M structure.
The expectation is that the stream uses IO for side effects, so this makes them to happen.
method K<M, Unit> Iter <M, A> (this K<Source, A> ma) Source #
where
M : MonadIO<M>
Force iteration of the stream, yielding a unit M structure.
The expectation is that the stream uses IO for side effects, so this makes them to happen.
method IO<A> Last <A> (this K<Source, A> ma) Source #
Force iteration of the stream, yielding the last structure processed
method K<M, A> Last <M, A> (this K<Source, A> ma) Source #
where
M : MonadIO<M>
Force iteration of the stream, yielding the last structure processed