Contents
- Source <A>
- Empty
- Read ()
- Map <B> (Func<A, B> f)
- Bind <B> (Func<A, Source<B>> f)
- ApplyBack <B> (Source<Func<A, B>> ff)
- Combine (Source<A> rhs)
- Choose (Source<A> rhs)
- Bind <B> (Func<A, K<Source, B>> f)
- ToProducerT <M> ()
- ToProducer <RT> ()
- + (Source<A> lhs, Source<A> rhs)
- | (Source<A> lhs, Source<A> rhs)
- SourceExtensions
- Source
Methods
Read value from the Source
Raises a Errors.SourceChannelClosed if the channel is closed or empty
Parameters
| returns | First available value from the channel | |
method Source<A> Combine (Source<A> rhs) Source #
Combine two Sourcees into a single Source. 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 Source<A> Choose (Source<A> rhs) Source #
Choose a value from the first Source to successfully yield
Parameters
| param | rhs | |
| returns | Value from this | |
method ProducerT<A, M, Unit> ToProducerT <M> () Source #
Convert Source to a ProducerT pipe component
Parameters
| type | M | Monad to lift (must support |
| returns |
| |
method Producer<RT, A, Unit> ToProducer <RT> () Source #
Convert Source to a Producer pipe component
Parameters
| returns |
| |
Operators
operator + (Source<A> lhs, Source<A> rhs) Source #
Combine two Sourcees into a single Source. 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 | (Source<A> lhs, Source<A> rhs) Source #
Choose a value from the first Source to successfully yield
Parameters
| param | lhs | Left hand side |
| param | rhs | Right hand side |
| returns | Value from the | |
class SourceExtensions Source #