LanguageExt.Core

LanguageExt.Core Effects Pipes RequestRespond

Contents

class Request <RT, UOut, UIn, DIn, DOut, A> Source #

where RT : struct, HasCancel<RT>

One of the algebraic cases of the Proxy type. This type represents a request.

Parameters

type RT

Aff system runtime

type UOut

Upstream out type

type UIn

Upstream in type

type DIn

Downstream in type

type DOut

Downstream uut type

type A

The monadic bound variable - it doesn't flow up or down stream, it works just like any bound monadic variable. If the effect represented by the Proxy ends, then this will be the result value.

When composing Proxy sub-types (like Producer, Pipe, Consumer, etc.)

Fields

field UOut Value Source #

field Func<UIn, Proxy<RT, UOut, UIn, DIn, DOut, A>> Next Source #

Constructors

constructor Request (UOut value, Func<UIn, Proxy<RT, UOut, UIn, DIn, DOut, A>> next) Source #

Methods

method Proxy<RT, UOut, UIn, DIn, DOut, A> ToProxy () Source #

method void Deconstruct (out UOut value, out Func<UIn, Proxy<RT, UOut, UIn, DIn, DOut, A>> fun) Source #

method Proxy<RT, UOut, UIn, C1, C, A> For <C1, C> (Func<DOut, Proxy<RT, UOut, UIn, C1, C, DIn>> body) Source #

method Proxy<RT, UOut, UIn, DIn, DOut, S> Action <S> (Proxy<RT, UOut, UIn, DIn, DOut, S> r) Source #

method Proxy<RT, UOutA, AUInA, DIn, DOut, A> ReplaceRequest <UOutA, AUInA> ( Func<UOut, Proxy<RT, UOutA, AUInA, DIn, DOut, UIn>> lhs) Source #

method Proxy<RT, UOut, UIn, DInC, DOutC, A> ReplaceRespond <DInC, DOutC> ( Func<DOut, Proxy<RT, UOut, UIn, DInC, DOutC, DIn>> rhs) Source #

method Proxy<RT, UOutA, AUInA, DIn, DOut, A> PairEachRequestWithRespond <UOutA, AUInA> ( Func<UOut, Proxy<RT, UOutA, AUInA, UOut, UIn, A>> lhs) Source #

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

method Proxy<RT, UOut, UIn, DInC, DOutC, A> PairEachRespondWithRequest <DInC, DOutC> ( Func<DOut, Proxy<RT, DIn, DOut, DInC, DOutC, A>> rhs) Source #

method Proxy<RT, DOut, DIn, UIn, UOut, A> Reflect () Source #

method Proxy<RT, UOut, UIn, DIn, DOut, A> Observe () Source #

method Proxy<RT, UOut, UIn, DIn, DOut, S> Bind <S> (Func<A, Proxy<RT, UOut, UIn, DIn, DOut, S>> f) Source #

method Proxy<RT, UOut, UIn, DIn, DOut, S> Map <S> (Func<A, S> f) Source #

class Respond <RT, UOut, UIn, DIn, DOut, A> Source #

where RT : struct, HasCancel<RT>

One of the algebraic cases of the Proxy type. This type represents a response.

Parameters

type RT

Aff system runtime

type UOut

Upstream out type

type UIn

Upstream in type

type DIn

Downstream in type

type DOut

Downstream uut type

type A

The monadic bound variable - it doesn't flow up or down stream, it works just like any bound monadic variable. If the effect represented by the Proxy ends, then this will be the result value.

When composing Proxy sub-types (like Producer, Pipe, Consumer, etc.)

Fields

field DOut Value Source #

field Func<DIn, Proxy<RT, UOut, UIn, DIn, DOut, A>> Next Source #

Constructors

constructor Respond (DOut value, Func<DIn, Proxy<RT, UOut, UIn, DIn, DOut, A>> next) Source #

Methods

method Proxy<RT, UOut, UIn, DIn, DOut, A> ToProxy () Source #

method Proxy<RT, UOut, UIn, DIn, DOut, S> Bind <S> (Func<A, Proxy<RT, UOut, UIn, DIn, DOut, S>> f) Source #

method Proxy<RT, UOut, UIn, DIn, DOut, S> Map <S> (Func<A, S> f) Source #

method Proxy<RT, UOut, UIn, C1, C, A> For <C1, C> (Func<DOut, Proxy<RT, UOut, UIn, C1, C, DIn>> body) Source #

method Proxy<RT, UOut, UIn, DIn, DOut, S> Action <S> (Proxy<RT, UOut, UIn, DIn, DOut, S> r) Source #

method Proxy<RT, UOutA, AUInA, DIn, DOut, A> ReplaceRequest <UOutA, AUInA> (Func<UOut, Proxy<RT, UOutA, AUInA, DIn, DOut, UIn>> lhs) Source #

method Proxy<RT, UOut, UIn, DInC, DOutC, A> ReplaceRespond <DInC, DOutC> ( Func<DOut, Proxy<RT, UOut, UIn, DInC, DOutC, DIn>> rhs) Source #

method Proxy<RT, UOutA, AUInA, DIn, DOut, A> PairEachRequestWithRespond <UOutA, AUInA> ( Func<UOut, Proxy<RT, UOutA, AUInA, UOut, UIn, A>> fb1) Source #

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

method Proxy<RT, UOut, UIn, DInC, DOutC, A> PairEachRespondWithRequest <DInC, DOutC> ( Func<DOut, Proxy<RT, DIn, DOut, DInC, DOutC, A>> rhs) Source #

method Proxy<RT, DOut, DIn, UIn, UOut, A> Reflect () Source #

method Proxy<RT, UOut, UIn, DIn, DOut, A> Observe () Source #

method void Deconstruct (out DOut value, out Func<DIn, Proxy<RT, UOut, UIn, DIn, DOut, A>> fun) Source #