LanguageExt.Core ► Effects ► Pipes ► Queue
Contents
- Queue <RT, OUT, A>
- Enqueue (OUT value)
- EnqueueEff (OUT value)
- Done ()
- DoneEff
- ToProxy ()
- Bind <S> (Func<A, Proxy<RT, Void, Unit, Unit, OUT, S>> f)
- Map <B> (Func<A, B> f)
- Select <B> (Func<A, B> f)
- For <C1, C> (Func<OUT, Proxy<RT, Void, Unit, C1, C, Unit>> body)
- Action <B> (Proxy<RT, Void, Unit, Unit, OUT, B> r)
- PairEachRequestWithRespond <UOutA, AUInA> (Func<Void, Proxy<RT, UOutA, AUInA, Void, Unit, A>> lhs)
- ReplaceRequest <UOutA, AUInA> (Func<Void, Proxy<RT, UOutA, AUInA, Unit, OUT, Unit>> lhs)
- PairEachRespondWithRequest <DInC, DOutC> (Func<OUT, Proxy<RT, Unit, OUT, DInC, DOutC, A>> rhs)
- ReplaceRespond <DInC, DOutC> (Func<OUT, Proxy<RT, Void, Unit, DInC, DOutC, Unit>> rhs)
- Reflect ()
- Observe ()
- | (Queue<RT, OUT, A> p1, Consumer<RT, OUT, A> p2)
- | (Queue<RT, OUT, A> p1, Consumer<OUT, A> p2)
class Queue <RT, OUT, A> Source #
Properties
Methods
method Eff<RT, Unit> EnqueueEff (OUT value) Source #
Enqueue an item
method Proxy<RT, Void, Unit, Unit, OUT, S> Bind <S> (Func<A, Proxy<RT, Void, Unit, Unit, OUT, S>> f) Source #
method Proxy<RT, Void, Unit, C1, C, A> For <C1, C> (Func<OUT, Proxy<RT, Void, Unit, C1, C, Unit>> body) Source #
method Proxy<RT, Void, Unit, Unit, OUT, B> Action <B> (Proxy<RT, Void, Unit, Unit, OUT, B> r) Source #
method Proxy<RT, UOutA, AUInA, Unit, OUT, A> PairEachRequestWithRespond <UOutA, AUInA> (Func<Void, Proxy<RT, UOutA, AUInA, Void, Unit, A>> lhs) Source #
(f +>> p) pairs each 'request' in this with a 'respond' in lhs.
method Proxy<RT, UOutA, AUInA, Unit, OUT, A> ReplaceRequest <UOutA, AUInA> (Func<Void, Proxy<RT, UOutA, AUInA, Unit, OUT, Unit>> lhs) Source #
method Proxy<RT, Void, Unit, DInC, DOutC, A> PairEachRespondWithRequest <DInC, DOutC> (Func<OUT, Proxy<RT, Unit, OUT, DInC, DOutC, A>> rhs) Source #
method Proxy<RT, Void, Unit, DInC, DOutC, A> ReplaceRespond <DInC, DOutC> (Func<OUT, Proxy<RT, Void, Unit, DInC, DOutC, Unit>> rhs) Source #