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 |
|