LanguageExt.Pipes ► Consumer

Contents

Consumer <RT, IN, A> (PipeT<IN, Void, Eff<RT>, A> Proxy)

Map (Func<A, B> f)
MapM (Func<Eff<RT, A>, Eff<RT, B>> f)
MapIO (Func<IO<A>, IO> f)
ApplyBack (Consumer<RT, IN, Func<A, B>> ff)
Action (Consumer<RT, IN, B> fb)
Bind (Func<A, Consumer<RT, IN, B>> f)
Bind (Func<A, IO> f)
Bind (Func<A, Eff<RT, B>> f)
Bind (Func<A, Pure> f)
Bind (Func<A, Lift> f)
Select (Func<A, B> f)
SelectMany <B, C> (Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g)
SelectMany <B, C> (Func<A, Eff<RT, B>> f, Func<A, B, C> g)
SelectMany <B, C> (Func<A, IO> f, Func<A, B, C> g)
SelectMany <B, C> (Func<A, Pure> f, Func<A, B, C> g)
SelectMany <B, C> (Func<A, Lift> f, Func<A, B, C> g)

ConsumerExtensions

ToConsumer <RT, IN, A> (this K<PipeT<IN, Void, Eff<RT>>, A> pipe)
ToConsumer <RT, IN, A> (this K<Pipe<RT, IN, Void>, A> pipe)
As <RT, IN, A> (this K<Consumer<RT, IN>, A> ma)
SelectMany <RT, IN, A, B, C> ( this K<Eff<RT>, A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g)
SelectMany <RT, IN, A, B, C> ( this IO<A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g)
SelectMany <RT, IN, A, B, C> ( this Pure<A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g)
SelectMany <RT, IN, A, B, C> ( this Lift<A> ff, Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g)
Bind <RT, IN, A, B> ( this K<Eff<RT>, A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B> g)
Bind <RT, IN, A, B> ( this IO<A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B> g)
Bind <RT, IN, A, B> ( this Pure<A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B> g)
Bind <RT, IN, A, B> ( this Lift<A> ff, Func<A, Consumer<RT, IN, B>> f, Func<A, B> g)
SelectMany <RT, IN, A, C> ( this K<Consumer<RT, IN>, A> ma, Func<A, Guard<Error, Unit>> bind, Func<A, Unit, C> project)
SelectMany <RT, IN, B, C> ( this Guard<Error, Unit> ma, Func<Unit, K<Consumer<RT, IN>, B>> bind, Func<Unit, B, C> project)

Consumer

awaiting <RT, IN> ()
awaitIgnore <RT, IN> ()
pure <RT, IN, A> (A value)
error <RT, IN, A> (Error value)
empty <RT, IN, A> ()
lift <RT, IN, A> (Func<A> f)
liftT <RT, IN, A> (Func<Consumer<RT, IN, A>> f)
liftT <RT, IN, A> (Func<ValueTask<Consumer<RT, IN, A>>> f)
liftT <RT, IN, A> (ValueTask<Consumer<RT, IN, A>> f)
liftM <RT, IN, A> (K<Eff<RT>, A> ma)
liftIO <RT, IN, A> (IO<A> ma)
repeat <RT, IN, A> (Consumer<RT, IN, A> ma)
repeat <RT, IN, A> (Schedule schedule, Consumer<RT, IN, A> ma)
repeatM <RT, IN, A> (K<Eff<RT>, A> ma)
repeatM <RT, IN, A> (Schedule schedule, K<Eff<RT>, A> ma)

Consumer <RT, IN>

record Consumer <RT, IN, A> (PipeT<IN, Void, Eff<RT>, A> Proxy) Source #

Consumer streaming consumer monad-transformer instance

Unlike the general purpose ConsumerT, which will lift any monad, this type only lifts the Eff monad.

Methods

method Consumer<RT, IN, B> Map (Func<A, B> f) Source #

method Consumer<RT, IN, B> MapM (Func<Eff<RT, A>, Eff<RT, B>> f) Source #

method Consumer<RT, IN, B> MapIO (Func<IO<A>, IO> f) Source #

method Consumer<RT, IN, B> ApplyBack (Consumer<RT, IN, Func<A, B>> ff) Source #

method Consumer<RT, IN, B> Action (Consumer<RT, IN, B> fb) Source #

method Consumer<RT, IN, B> Bind (Func<A, Consumer<RT, IN, B>> f) Source #

method Consumer<RT, IN, B> Bind (Func<A, IO> f) Source #

method Consumer<RT, IN, B> Bind (Func<A, Eff<RT, B>> f) Source #

method Consumer<RT, IN, B> Bind (Func<A, Pure> f) Source #

method Consumer<RT, IN, B> Bind (Func<A, Lift> f) Source #

method Consumer<RT, IN, B> Select (Func<A, B> f) Source #

method Consumer<RT, IN, C> SelectMany <B, C> (Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g) Source #

method Consumer<RT, IN, C> SelectMany <B, C> (Func<A, Eff<RT, B>> f, Func<A, B, C> g) Source #

method Consumer<RT, IN, C> SelectMany <B, C> (Func<A, IO> f, Func<A, B, C> g) Source #

method Consumer<RT, IN, C> SelectMany <B, C> (Func<A, Pure> f, Func<A, B, C> g) Source #

method Consumer<RT, IN, C> SelectMany <B, C> (Func<A, Lift> f, Func<A, B, C> g) Source #

class ConsumerExtensions Source #

Methods

method Consumer<RT, IN, A> ToConsumer <RT, IN, A> (this K<PipeT<IN, Void, Eff<RT>>, A> pipe) Source #

Transformation from PipeT to Consumer.

method Consumer<RT, IN, A> ToConsumer <RT, IN, A> (this K<Pipe<RT, IN, Void>, A> pipe) Source #

Transformation from Pipe to Consumer.

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

Downcast

method Consumer<RT, IN, C> SelectMany <RT, IN, A, B, C> ( this K<Eff<RT>, A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g) Source #

Monad bind

method Consumer<RT, IN, C> SelectMany <RT, IN, A, B, C> ( this IO<A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g) Source #

Monad bind

method Consumer<RT, IN, C> SelectMany <RT, IN, A, B, C> ( this Pure<A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g) Source #

Monad bind

method Consumer<RT, IN, C> SelectMany <RT, IN, A, B, C> ( this Lift<A> ff, Func<A, Consumer<RT, IN, B>> f, Func<A, B, C> g) Source #

Monad bind

method Consumer<RT, IN, B> Bind <RT, IN, A, B> ( this K<Eff<RT>, A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B> g) Source #

Monad bind

method Consumer<RT, IN, B> Bind <RT, IN, A, B> ( this IO<A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B> g) Source #

Monad bind

method Consumer<RT, IN, B> Bind <RT, IN, A, B> ( this Pure<A> ma, Func<A, Consumer<RT, IN, B>> f, Func<A, B> g) Source #

Monad bind

method Consumer<RT, IN, B> Bind <RT, IN, A, B> ( this Lift<A> ff, Func<A, Consumer<RT, IN, B>> f, Func<A, B> g) Source #

Monad bind

method Consumer<RT, IN, C> SelectMany <RT, IN, A, C> ( this K<Consumer<RT, IN>, A> ma, Func<A, Guard<Error, Unit>> bind, Func<A, Unit, C> project) Source #

Monad bind operation

method Consumer<RT, IN, C> SelectMany <RT, IN, B, C> ( this Guard<Error, Unit> ma, Func<Unit, K<Consumer<RT, IN>, B>> bind, Func<Unit, B, C> project) Source #

Monad bind operation

class Consumer Source #

ConsumerT streaming consumer monad-transformer

Methods

method Consumer<RT, IN, IN> awaiting <RT, IN> () Source #

Await a value from upstream

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
returns

method Consumer<RT, IN, Unit> awaitIgnore <RT, IN> () Source #

Await a value from upstream and then ignore it

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
returns

method Consumer<RT, IN, A> pure <RT, IN, A> (A value) Source #

Create a consumer that simply returns a bound value without awaiting anything

Parameters

type	RT	Effect runtime type
type	IN	Stream value to await
type	A	Bound value type
returns

method Consumer<RT, IN, A> error <RT, IN, A> (Error value) Source #

Create a consumer that always fails

Parameters

type	RT	Effect runtime type
type	IN	Stream value to await
type	A	Bound value type
returns

method Consumer<RT, IN, A> empty <RT, IN, A> () Source #

Create a consumer that yields nothing at all

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> lift <RT, IN, A> (Func<A> f) Source #

Create a consumer that simply returns a bound value without yielding anything

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> liftT <RT, IN, A> (Func<Consumer<RT, IN, A>> f) Source #

Create a lazy consumer

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> liftT <RT, IN, A> (Func<ValueTask<Consumer<RT, IN, A>>> f) Source #

Create an asynchronous lazy consumer

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> liftT <RT, IN, A> (ValueTask<Consumer<RT, IN, A>> f) Source #

Create an asynchronous consumer

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> liftM <RT, IN, A> (K<Eff<RT>, A> ma) Source #

Create a consumer that simply returns the bound value of the lifted monad without yielding anything

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> liftIO <RT, IN, A> (IO<A> ma) Source #

Create a consumer that simply returns the bound value of the lifted monad without yielding anything

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> repeat <RT, IN, A> (Consumer<RT, IN, A> ma) Source #

Continually repeat the provided operation

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> repeat <RT, IN, A> (Schedule schedule, Consumer<RT, IN, A> ma) Source #

Repeat the provided operation based on the schedule provided

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> repeatM <RT, IN, A> (K<Eff<RT>, A> ma) Source #

Continually lift & repeat the provided operation

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

method Consumer<RT, IN, A> repeatM <RT, IN, A> (Schedule schedule, K<Eff<RT>, A> ma) Source #

Repeat the provided operation based on the schedule provided

Parameters

type	RT	Effect runtime type
type	IN	Stream value to consume
type	A	Bound value type
returns

class Consumer <RT, IN> Source #