Contents
- ConsumerT <IN, M, A> (PipeT<IN, Void, M, A> Proxy)
- Map <B> (Func<A, B> f)
- MapM <B> (Func<K<M, A>, K<M, B>> f)
- MapIO <B> (Func<IO<A>, IO<B>> f)
- ApplyBack <B> (ConsumerT<IN, M, Func<A, B>> ff)
- Action <B> (ConsumerT<IN, M, B> fb)
- Bind <B> (Func<A, ConsumerT<IN, M, B>> f)
- Bind <B> (Func<A, IO<B>> f)
- Bind <B> (Func<A, K<M, B>> f)
- Bind <B> (Func<A, Pure<B>> f)
- Bind <B> (Func<A, Lift<B>> f)
- Select <B> (Func<A, B> f)
- SelectMany <B, C> (Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g)
- SelectMany <B, C> (Func<A, K<M, B>> f, Func<A, B, C> g)
- SelectMany <B, C> (Func<A, IO<B>> f, Func<A, B, C> g)
- SelectMany <B, C> (Func<A, Pure<B>> f, Func<A, B, C> g)
- SelectMany <B, C> (Func<A, Lift<B>> f, Func<A, B, C> g)
- ConsumerTExtensions
- ToConsumer <IN, M, A> (this K<PipeT<IN, Void, M>, A> pipe)
- As <IN, M, A> (this K<ConsumerT<IN, M>, A> ma)
- ToEff <RT, IN, A> (this K<ConsumerT<IN, Eff<RT>>, A> ma)
- SelectMany <IN, M, A, B, C> ( this K<M, A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g)
- SelectMany <IN, M, A, B, C> ( this IO<A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g)
- SelectMany <IN, M, A, B, C> ( this Pure<A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g)
- SelectMany <IN, M, A, B, C> ( this Lift<A> ff, Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g)
- Bind <IN, M, A, B> ( this K<M, A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B> g)
- Bind <IN, M, A, B> ( this IO<A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B> g)
- Bind <IN, M, A, B> ( this Pure<A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B> g)
- Bind <IN, M, A, B> ( this Lift<A> ff, Func<A, ConsumerT<IN, M, B>> f, Func<A, B> g)
- SelectMany <IN, E, M, A, C> ( this K<ConsumerT<IN, M>, A> ma, Func<A, Guard<E, Unit>> bind, Func<A, Unit, C> project)
- SelectMany <IN, E, M, B, C> ( this Guard<E, Unit> ma, Func<Unit, K<ConsumerT<IN, M>, B>> bind, Func<Unit, B, C> project)
- ConsumerT
- awaiting <M, IN> ()
- awaitIgnore <M, IN> ()
- pure <IN, M, A> (A value)
- fail <IN, E, M, A> (E value)
- error <IN, M, A> (Error value)
- empty <IN, M, A> ()
- lift <IN, M, A> (Func<A> f)
- liftT <IN, M, A> (Func<ConsumerT<IN, M, A>> f)
- liftT <IN, M, A> (Func<ValueTask<ConsumerT<IN, M, A>>> f)
- liftT <IN, M, A> (ValueTask<ConsumerT<IN, M, A>> f)
- liftM <IN, M, A> (K<M, A> ma)
- liftIO <IN, M, A> (IO<A> ma)
- repeat <IN, M, A> (ConsumerT<IN, M, A> ma)
- repeat <IN, M, A> (Schedule schedule, ConsumerT<IN, M, A> ma)
- repeatM <IN, M, A> (K<M, A> ma)
- repeatM <IN, M, A> (Schedule schedule, K<M, A> ma)
- ConsumerT <IN, M>
record ConsumerT <IN, M, A> (PipeT<IN, Void, M, A> Proxy) Source #
ConsumerT streaming consumer monad-transformer instance
Methods
method ConsumerT<IN, M, C> SelectMany <B, C> (Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g) Source #
method ConsumerT<IN, M, C> SelectMany <B, C> (Func<A, K<M, B>> f, Func<A, B, C> g) Source #
method ConsumerT<IN, M, C> SelectMany <B, C> (Func<A, IO<B>> f, Func<A, B, C> g) Source #
method ConsumerT<IN, M, C> SelectMany <B, C> (Func<A, Pure<B>> f, Func<A, B, C> g) Source #
method ConsumerT<IN, M, C> SelectMany <B, C> (Func<A, Lift<B>> f, Func<A, B, C> g) Source #
class ConsumerTExtensions Source #
Methods
method ConsumerT<IN, M, A> ToConsumer <IN, M, A> (this K<PipeT<IN, Void, M>, A> pipe) Source #
Transformation from PipeT to ConsumerT.
method ConsumerT<IN, M, A> As <IN, M, A> (this K<ConsumerT<IN, M>, A> ma) Source #
Downcast
method Consumer<RT, IN, A> ToEff <RT, IN, A> (this K<ConsumerT<IN, Eff<RT>>, A> ma) Source #
Convert to the Eff version of Consumer
method ConsumerT<IN, M, C> SelectMany <IN, M, A, B, C> ( this K<M, A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g) Source #
Monad bind
method ConsumerT<IN, M, C> SelectMany <IN, M, A, B, C> ( this IO<A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g) Source #
Monad bind
method ConsumerT<IN, M, C> SelectMany <IN, M, A, B, C> ( this Pure<A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g) Source #
Monad bind
method ConsumerT<IN, M, C> SelectMany <IN, M, A, B, C> ( this Lift<A> ff, Func<A, ConsumerT<IN, M, B>> f, Func<A, B, C> g) Source #
Monad bind
method ConsumerT<IN, M, B> Bind <IN, M, A, B> ( this K<M, A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B> g) Source #
Monad bind
method ConsumerT<IN, M, B> Bind <IN, M, A, B> ( this IO<A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B> g) Source #
Monad bind
method ConsumerT<IN, M, B> Bind <IN, M, A, B> ( this Pure<A> ma, Func<A, ConsumerT<IN, M, B>> f, Func<A, B> g) Source #
Monad bind
method ConsumerT<IN, M, B> Bind <IN, M, A, B> ( this Lift<A> ff, Func<A, ConsumerT<IN, M, B>> f, Func<A, B> g) Source #
Monad bind
method ConsumerT<IN, M, C> SelectMany <IN, E, M, A, C> ( this K<ConsumerT<IN, M>, A> ma, Func<A, Guard<E, Unit>> bind, Func<A, Unit, C> project) Source #
Monad bind operation
method ConsumerT<IN, M, C> SelectMany <IN, E, M, B, C> ( this Guard<E, Unit> ma, Func<Unit, K<ConsumerT<IN, M>, B>> bind, Func<Unit, B, C> project) Source #
Monad bind operation
ConsumerT streaming consumer monad-transformer
Methods
method ConsumerT<IN, M, IN> awaiting <M, IN> () Source #
Await a value from upstream
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| returns | ||
method ConsumerT<IN, M, Unit> awaitIgnore <M, IN> () Source #
Await a value from upstream and then ignore it
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| returns | ||
method ConsumerT<IN, M, A> pure <IN, M, A> (A value) Source #
Create a consumer that simply returns a bound value without awaiting anything
Parameters
| type | IN | Stream value to await |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> fail <IN, E, M, A> (E value) Source #
Create a consumer that always fails
Parameters
| type | IN | Stream value to await |
| type | E | Failure type |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> error <IN, M, A> (Error value) Source #
Create a consumer that always fails
Parameters
| type | IN | Stream value to await |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> empty <IN, M, A> () Source #
Create a consumer that yields nothing at all
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> lift <IN, M, A> (Func<A> f) Source #
Create a consumer that simply returns a bound value without yielding anything
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> liftT <IN, M, A> (Func<ConsumerT<IN, M, A>> f) Source #
Create a lazy consumer
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> liftT <IN, M, A> (Func<ValueTask<ConsumerT<IN, M, A>>> f) Source #
Create an asynchronous lazy consumer
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> liftT <IN, M, A> (ValueTask<ConsumerT<IN, M, A>> f) Source #
Create an asynchronous consumer
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> liftM <IN, M, A> (K<M, A> ma) Source #
Create a consumer that simply returns the bound value of the lifted monad without yielding anything
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> liftIO <IN, M, A> (IO<A> ma) Source #
Create a consumer that simply returns the bound value of the lifted monad without yielding anything
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> repeat <IN, M, A> (ConsumerT<IN, M, A> ma) Source #
Continually repeat the provided operation
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||
method ConsumerT<IN, M, A> repeat <IN, M, A> (Schedule schedule, ConsumerT<IN, M, A> ma) Source #
Repeat the provided operation based on the schedule provided
Parameters
| type | IN | Stream value to consume |
| type | M | Lifted monad type |
| type | A | Bound value type |
| returns | ||