Packages

package root

This is the API documentation for the Monix library.

monix.execution exposes lower level primitives for dealing with asynchronous execution:

monix.execution.atomic exposes the Atomic types, as alternative to java.util.concurrent.atomic
monix.execution.cancelables contains several useful Cancelable implementations
monix.execution.schedulers contains several useful Scheduler implementations
monix.execution.rstreams contains helpers for dealing with the Reactive Streams specification
monix.execution.misc provides miscellaneous primitives useful for dealing with concurrency

monix.eval is for dealing with evaluation of results, thus exposing Task and Coeval.

monix.reactive exposes the Observable pattern:

monix.reactive.exceptions groups some exceptions thrown by the implementation
monix.reactive.observables groups reusable Observable implementations
monix.reactive.observers groups reusable Observer implementations
monix.reactive.subjects exposes Subject and ConcurrentSubject, which are implementations of hot observables that function both as input and output

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

package monix

package reactive

package exceptions

BufferOverflowException

CompositeException

DownstreamTimeoutException

MultipleSubscribersException

UpstreamTimeoutException

package internal

package observables

package observers

package subjects

exceptions

class BufferOverflowException extends RuntimeException
An exception emitted on buffer overflow, like when using OverflowStrategy.Fail.
case class CompositeException (errors: Seq[Throwable]) extends RuntimeException with Product with Serializable
A composite exception represents a list of exceptions that were caught while delaying errors in the processing of observables.
A composite exception represents a list of exceptions that were caught while delaying errors in the processing of observables.
Used in operators such as mergeDelayErrors, concatDelayError, combineLatestDelayError, etc...
final case class DownstreamTimeoutException (timeout: FiniteDuration) extends TimeoutException with Product with Serializable
final case class MultipleSubscribersException (observableType: String) extends RuntimeException with Product with Serializable
The MultipleSubscribersException happens for hot observables that support a single subscriber.
final case class UpstreamTimeoutException (timeout: FiniteDuration) extends TimeoutException with Product with Serializable

Packages