package reactive
- Alphabetic
- Public
- All
Type Members
-
trait
Consumer[-In, +R] extends (Observable[In]) ⇒ Task[R] with Serializable
The
Consumeris a specification of how to consume an observable.The
Consumeris a specification of how to consume an observable.It is a factory of subscribers with a completion callback attached, being effectively a way to transform observables into tasks for less error prone consuming of streams.
-
sealed abstract
class
MulticastStrategy[+A] extends Serializable
The
MulticastStrategyspecifies the strategy for building data-sources that are shared between multiple subscribers.The
MulticastStrategyspecifies the strategy for building data-sources that are shared between multiple subscribers.By default observables tend to be cold.
-
sealed abstract
class
Notification[+A] extends Serializable
Used by Observable.materialize.
-
trait
Observable[+A] extends ObservableLike[A, Observable]
The Observable type that implements the Reactive Pattern.
The Observable type that implements the Reactive Pattern.
Provides methods of subscribing to the Observable and operators for combining observable sources, filtering, modifying, throttling, buffering, error handling and others.
See the available documentation at: https://monix.io
-
trait
Observer[-A] extends Serializable
The Observer from the Rx pattern is the trio of callbacks that get subscribed to an Observable for receiving events.
The Observer from the Rx pattern is the trio of callbacks that get subscribed to an Observable for receiving events.
The events received must follow the Rx grammar, which is: onNext * (onComplete | onError)?
That means an Observer can receive zero or multiple events, the stream ending either in one or zero
onCompleteoronError(just one, not both), and after onComplete or onError, a well behavedObservableimplementation shouldn't send any more onNext events. -
sealed abstract
class
OverflowStrategy[+A] extends Serializable
Represents the buffering overflowStrategy chosen for actions that need buffering, instructing the pipeline what to do when the buffer is full.
Represents the buffering overflowStrategy chosen for actions that need buffering, instructing the pipeline what to do when the buffer is full.
For the available policies, see:
- Unbounded - Fail - BackPressure
Used in BufferedSubscriber to implement buffering when concurrent actions are needed, such as in Channels or in Observable.merge.
-
abstract
class
Pipe[I, +O] extends ObservableLike[O, [+α]Pipe[I, α]]
Represents a factory for an input/output channel for broadcasting input to multiple subscribers.
Value Members
-
object
Consumer extends Serializable
The companion object of Consumer, defines consumer builders.
-
object
MulticastStrategy extends Serializable
The MulticastStrategy enumerated.
- object Notification extends Serializable
-
object
Observable extends Serializable
Observable builders.
- object Observer extends Serializable
- object OverflowStrategy extends Serializable
- object Pipe extends Serializable
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.eval is for dealing with evaluation of results, thus exposing Task and Coeval.
monix.reactive exposes the
Observablepattern:Observableimplementationsmonix.types implements type-class shims, to be translated to type-classes provided by libraries such as Cats or Scalaz.
monix.cats is the optional integration with the Cats library, providing translations for the types described in
monix.types.monix.scalaz is the optional integration with the Scalaz library, providing translations for the types described in
monix.types.