trait ChannelF[F[_], E, A] extends Serializable
Channel is a communication channel that can be consumed via
consume.
Examples:
- Source
- ChannelF.scala
- Alphabetic
- By Inheritance
- ChannelF
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def consume: Resource[F, ConsumerF[F, E, A]]
Create a ConsumerF value that can be used to consume events from the channel.
Create a ConsumerF value that can be used to consume events from the channel.
Note in case multiple consumers are created, all of them will see the events being pushed, so a broadcasting setup is possible. Also multiple workers can consumer from the same
ConsumerFvalue, to share the load.The returned value is a Resource, because a consumer can be unsubscribed from the channel, with its internal buffer being garbage collected.
- See also
consumeWithConfig for fine tuning the internal buffer of the created consumer
- abstract def consumeWithConfig(config: Config): Resource[F, ConsumerF[F, E, A]]
Version of consume that allows for fine tuning the underlying buffer used.
Version of consume that allows for fine tuning the underlying buffer used.
- config
is configuration for the created buffer, see ConsumerF.Config for details
- Annotations
- @UnsafeProtocol()
This is the API documentation for the Monix library.
Package Overview
monix.execution exposes lower level primitives for dealing with asynchronous execution:
Atomictypes, as alternative tojava.util.concurrent.atomicmonix.catnap exposes pure abstractions built on top of the Cats-Effect type classes:
monix.eval is for dealing with evaluation of results, thus exposing Task and Coeval.
monix.reactive exposes the
Observablepattern:Observableimplementationsmonix.tail exposes Iterant for purely functional pull based streaming:
BatchandBatchCursor, the alternatives to Scala'sIterableandIteratorrespectively that we are using within Iterant's encodingYou can control evaluation with type you choose - be it Task, Coeval, cats.effect.IO or your own as long as you provide correct cats-effect or cats typeclass instance.