LanguageExt.Pipes ► Queue

Contents

Queue <OUT, M, A>

Enqueue (OUT value)
EnqueueM (OUT value)
Done ()
DoneM
ToProxy ()
Bind <S> (Func<A, Proxy<Void, Unit, Unit, OUT, M, S>> f)
Map (Func<A, B> f)
Select (Func<A, B> f)
For <C1, C> (Func<OUT, Proxy<Void, Unit, C1, C, M, Unit>> body)
Action (Proxy<Void, Unit, Unit, OUT, M, B> r)
PairEachRequestWithRespond <UOutA, AUInA> ( Func<Void, Proxy<UOutA, AUInA, Void, Unit, M, A>> lhs)
ReplaceRequest <UOutA, AUInA> ( Func<Void, Proxy<UOutA, AUInA, Unit, OUT, M, Unit>> lhs)
PairEachRespondWithRequest <DInC, DOutC> ( Func<OUT, Proxy<Unit, OUT, DInC, DOutC, M, A>> rhs)
ReplaceRespond <DInC, DOutC> ( Func<OUT, Proxy<Void, Unit, DInC, DOutC, M, Unit>> rhs)
Reflect ()
Observe ()
| (Queue<OUT, M, A> p1, Consumer<OUT, M, A> p2)
| (Queue<OUT, M, A> p1, Consumer<OUT, A> p2)
ToString ()

record Queue <OUT, M, A> Source #

where M : Monad<M>

Properties

property K<M, Unit> DoneM Source #

Mark the Queue as done and cancel any Effect that it is in

Methods

method Unit Enqueue (OUT value) Source #

Enqueue an item

method K<M, Unit> EnqueueM (OUT value) Source #

Enqueue an item

method Unit Done () Source #

Mark the Queue as done and cancel any Effect that it is in

method Proxy<Void, Unit, Unit, OUT, M, A> ToProxy () Source #

method Proxy<Void, Unit, Unit, OUT, M, S> Bind <S> (Func<A, Proxy<Void, Unit, Unit, OUT, M, S>> f) Source #

method Proxy<Void, Unit, Unit, OUT, M, B> Map (Func<A, B> f) Source #

method Producer<OUT, M, B> Select (Func<A, B> f) Source #

method Proxy<Void, Unit, C1, C, M, A> For <C1, C> (Func<OUT, Proxy<Void, Unit, C1, C, M, Unit>> body) Source #

method Proxy<Void, Unit, Unit, OUT, M, B> Action (Proxy<Void, Unit, Unit, OUT, M, B> r) Source #

method Proxy<UOutA, AUInA, Unit, OUT, M, A> PairEachRequestWithRespond <UOutA, AUInA> ( Func<Void, Proxy<UOutA, AUInA, Void, Unit, M, A>> lhs) Source #

(f +>> p) pairs each 'request' in this with a 'respond' in lhs.

method Proxy<UOutA, AUInA, Unit, OUT, M, A> ReplaceRequest <UOutA, AUInA> ( Func<Void, Proxy<UOutA, AUInA, Unit, OUT, M, Unit>> lhs) Source #

method Proxy<Void, Unit, DInC, DOutC, M, A> PairEachRespondWithRequest <DInC, DOutC> ( Func<OUT, Proxy<Unit, OUT, DInC, DOutC, M, A>> rhs) Source #

method Proxy<Void, Unit, DInC, DOutC, M, A> ReplaceRespond <DInC, DOutC> ( Func<OUT, Proxy<Void, Unit, DInC, DOutC, M, Unit>> rhs) Source #

method Proxy<OUT, Unit, Unit, Void, M, A> Reflect () Source #

method Proxy<Void, Unit, Unit, OUT, M, A> Observe () Source #

method string ToString () Source #

Operators

operator | (Queue<OUT, M, A> p1, Consumer<OUT, M, A> p2) Source #

operator | (Queue<OUT, M, A> p1, Consumer<OUT, A> p2) Source #