Contents

Methods

method Source<A> As <A> (this K<Source, A> ma) Source #

Downcast

method Source<A> AsSource <A> (this Channel<A> items) Source #

method Source<A> AsSource <A> (this IEnumerable<A> items) Source #

method Source<A> AsSource <A> (this IAsyncEnumerable<A> items) Source #

method Source<A> AsSource <A> (this IObservable<A> items) 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

method IO<Seq<A>> Collect <A> (this K<Source, A> ma) Source #

Force iteration of the stream and collect all the values into a Seq.

method K<M, Seq<A>> Collect <M, A> (this K<Source, A> ma) Source #

where M : MonadIO<M>

Force iteration of the stream and collect all the values into a Seq.