Contents
- Outbox <A>
- Empty
- Read ()
- Map <B> (Func<A, B> f)
- Bind <B> (Func<A, Outbox<B>> f)
- ApplyBack <B> (Outbox<Func<A, B>> ff)
- Combine (Outbox<A> rhs)
- Choose (Outbox<A> rhs)
- Bind <B> (Func<A, K<Outbox, B>> f)
- ToProducerT <M> ()
- ToProducer <RT> ()
- + (Outbox<A> lhs, Outbox<A> rhs)
- | (Outbox<A> lhs, Outbox<A> rhs)
- OutboxExtensions
- Outbox
- Outbox
Methods
Read value from the outbox
Raises a Errors.OutboxChannelClosed if the channel is closed or empty
Parameters
| returns | First available value from the channel | |
method Outbox<A> Combine (Outbox<A> rhs) Source #
Combine two outboxes into a single outbox. The value streams are both merged into a new stream. Values are yielded as they become available.
Parameters
| param | rhs | Right hand side |
| returns | Merged stream of values | |
method Outbox<A> Choose (Outbox<A> rhs) Source #
Choose a value from the first Outbox to successfully yield
Parameters
| param | rhs | |
| returns | Value from this | |
method ProducerT<A, M, Unit> ToProducerT <M> () Source #
Convert Outbox to a ProducerT pipe component
Parameters
| type | M | Monad to lift (must support |
| returns |
| |
method Producer<RT, A, Unit> ToProducer <RT> () Source #
Convert Outbox to a Producer pipe component
Parameters
| returns |
| |
Operators
operator + (Outbox<A> lhs, Outbox<A> rhs) Source #
Combine two outboxes into a single outbox. The value streams are both merged into a new stream. Values are yielded as they become available.
Parameters
| param | lhs | Left hand side |
| param | rhs | Right hand side |
| returns | Merged stream of values | |
operator | (Outbox<A> lhs, Outbox<A> rhs) Source #
Choose a value from the first Outbox to successfully yield
Parameters
| param | lhs | Left hand side |
| param | rhs | Right hand side |
| returns | Value from the | |
class OutboxExtensions Source #