Constructor

Calling this will effectively cast the sub-type to the base.

This type wraps up a Proxy for convenience, and so it's a Proxy proxy. So calling this method isn't exactly the same as a cast operation, as it unwraps the Proxy from within. It has the same effect however, and removes a level of indirection

Monadic bind operation, for chaining Proxy computations together.

Lifts a pure function into the Proxy domain, causing it to map the bound value within

Monadic bind operation, for chaining Proxy computations together.

Monadic bind operation, for chaining Proxy computations together.

Monadic bind operation, for chaining Proxy computations together.

Lifts a pure function into the Proxy domain, causing it to map the bound value within

For(body) loops over the Proxy p replacing each yield with body

Applicative action

Invokes this Proxy, then the Proxy r

Used by the various composition functions and when composing proxies with the | operator. You usually wouldn't need to call this directly, instead either pipe them using | or call Proxy.compose(lhs, rhs)

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

Used by the various composition functions and when composing proxies with the | operator. You usually wouldn't need to call this directly, instead either pipe them using | or call Proxy.compose(lhs, rhs)

Used by the various composition functions and when composing proxies with the | operator. You usually wouldn't need to call this directly, instead either pipe them using | or call Proxy.compose(lhs, rhs)

Used by the various composition functions and when composing proxies with the | operator. You usually wouldn't need to call this directly, instead either pipe them using | or call Proxy.compose(lhs, rhs)

Reverse the arrows of the Proxy to find its dual.

Observe(lift (Pure(r))) = Observe(Pure(r))
Observe(lift (m.Bind(f))) = Observe(lift(m.Bind(x => lift(f(x)))))

This correctness comes at a small cost to performance, so use this function sparingly. This function is a convenience for low-level pipes implementers. You do not need to use observe if you stick to the safe API.

Monadic bind operation, for chaining Proxy computations together.

Monadic bind operation, for chaining Proxy computations together.

Monadic bind operation, for chaining Proxy computations together.

Monadic bind operation, for chaining Proxy computations together.

Compose a Producer and a Consumer together into an Effect.

Compose a Producer and a Consumer together into an Effect.

Chain one producer's set of yields after another

Monad return / pure

Send a value downstream (whilst in a producer)

This is the simpler version (fewer generic arguments required) of yield that works for producers.

Repeat a monadic action indefinitely, yielding each result

Repeat a monadic action indefinitely, yielding each result

Repeat a monadic action indefinitely, yielding each result

Repeat a monadic action indefinitely, yielding each result

Lift the IO monad into the Producer monad transformer (a specialism of the Proxy monad transformer)

Lift the IO monad into the Producer monad transformer (a specialism of the Proxy monad transformer)

Lift the IO monad into the Producer monad transformer (a specialism of the Proxy monad transformer)

Lift the IO monad into the Producer monad transformer (a specialism of the Proxy monad transformer)

Lift am IO monad into the Proxy monad transformer

Lift am IO monad into the Proxy monad transformer

Lift am IO monad into the Proxy monad transformer

Lift am IO monad into the Proxy monad transformer

Lift am IO monad into the Proxy monad transformer

Lift am IO monad into the Proxy monad transformer

Lift am IO monad into the Proxy monad transformer

Lift am IO monad into the Proxy monad transformer

Release a previously used resource

Folds values coming down-stream, when the predicate returns true the folded value is yielded

Folds values coming down-stream, when the predicate returns true the folded value is yielded

Folds values coming down-stream, when the predicate returns true the folded value is yielded

Folds values coming down-stream, when the predicate returns true the folded value is yielded

Merge a sequence of producers into a single producer

The merged producer completes when all component producers have completed

Merge an array of queues into a single producer

The merged producer completes when all component queues have completed

Merge an array of producers into a single producer

The merged producer completes when all component producers have completed

Merge an array of producers into a single producer

The merged producer completes when all component producers have completed

Merge a sequence of queues into a single producer

The merged producer completes when all component queues have completed

Merge a sequence of producers into a single producer

The merged producer completes when all component producers have completed