package observables
- Alphabetic
- Public
- All
Type Members
-
final
class
CachedObservable[+A] extends Observable[A]
A
CachedObservableis an observable that wraps a regular Observable, initiating the connection on the firstsubscribe()and then staying connected for as long as the source is emitting.A
CachedObservableis an observable that wraps a regular Observable, initiating the connection on the firstsubscribe()and then staying connected for as long as the source is emitting.NOTE: this is NOT a ConnectableObservable and being a hot data-source you've got no way to cancel the source.
-
trait
ConnectableObservable[+A] extends Observable[A]
Represents an Observable that waits for the call to
connect()before starting to emit elements to its subscriber(s).Represents an Observable that waits for the call to
connect()before starting to emit elements to its subscriber(s).Represents a hot observable (an observable that shares its data-source to multiple subscribers).
-
trait
GroupedObservable[K, +V] extends Observable[V]
A
GroupedObservableis an observable type generated byObservable.groupBy.A
GroupedObservableis an observable type generated byObservable.groupBy. It has the following properties:- comes accompanied with a
keyproperty after which the grouping was made- supports a single subscriber, throwing
IllegalStateExceptionif you attempt multiple subscriptions -
trait
ObservableLike[+A, Self[+T] <: ObservableLike[T, Self]] extends Serializable
Defines the available operations for observable-like instances.
-
final
class
RefCountObservable[+A] extends Observable[A]
A
RefCountObservableis an observable that wraps a ConnectableObservable, initiating the connection on the firstsubscribe()and then staying connected as long as there is at least one subscription active.
Value Members
- object CachedObservable extends Serializable
- object ConnectableObservable extends Serializable
- object GroupedObservable extends Serializable
- object ObservableLike extends Serializable
- object RefCountObservable 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.