Contents
- SinkT <M>
- SinkT <M, A>
- PostM (K<M, A> ma)
- Post (A value)
- Complete ()
- Fail (Error Error)
- Comap <X> (Func<X, A> f)
- Comap <X> (TransducerM<M, X, A> f)
- Combine (SinkT<M, A> rhs)
- Combine <X, B> (Func<X, (A Left, B Right)> f, SinkT<M, B> rhs)
- + (SinkT<M, A> lhs, SinkT<M, A> rhs)
- Empty
- Void
- ToConsumerT ()
- SinkTExtensions
- SinkT
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 | M | Lifted type |
| type | A | Value type |
Properties
Methods
method K<M, Unit> PostM (K<M, A> ma) Source #
Post a value to the sink
Raises Errors.NoSpaceInSink if the sink is full or closed.
Parameters
| param | ma | Value to post |
| returns | IO computation that represents the posting | |
method K<M, 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 SinkT<M, A> Combine (SinkT<M, 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 SinkT<M, X> Combine <X, B> (Func<X, (A Left, B Right)> f, SinkT<M, 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 () Source #
Convert the Sink to a ConsumerT pipe component
Parameters
| type | M | Monad to lift (must support |
| returns |
| |
class SinkTExtensions Source #