Contents
Sub modules
| DSL |
Entry point to a channel. Sinks receive values and propagate them through the
channel they're attached to. The behaviour depends on the Buffer type they
were created with.
Parameters
| type | A | Value type |
Properties
Methods
method IO<Unit> Post (A value) Source #
Post a value to the Sink
Raises Errors.NoSpaceInSink if the Sink is full or closed.
Parameters
| param | value | Value to post |
| returns | IO computation that represents the posting | |
method Sink<A> Combine (Sink<A> rhs) Source #
Combine two Sinks: lhs and rhs into a single Sink that takes incoming
values and then posts to the lhs and rhs Sinks.
method Sink<X> Combine <X, B> (Func<X, (A Left, B Right)> f, Sink<B> rhs) Source #
Combine two Sinks: lhs and rhs into a single Sink that takes incoming
values, maps them to an (A, B) tuple, and then posts the first and second
elements to the lhs and rhs Sinks.
method ConsumerT<A, M, Unit> ToConsumerT <M> () Source #
Convert the Sink to a ConsumerT pipe component
Parameters
| type | M | Monad to lift (must support |
| returns |
| |
method Consumer<RT, A, Unit> ToConsumer <RT> () Source #
Convert the Sink to a Consumer pipe component
Parameters
| returns |
| |