observables

Type Members

1. final class CachedObservable[+T] extends Observable[T]

   

   A CachedObservable is an observable that wraps a regular Observable, initiating the connection on the first subscribe() and then staying connected for as long as the source is emitting.

   A CachedObservable is an observable that wraps a regular Observable, initiating the connection on the first subscribe() 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.

2. trait ConnectableObservable[+T] extends Observable[T]

   

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

3. trait GroupedObservable[K, +V] extends Observable[V]

   

   A GroupedObservable is an observable type generated by Observable.groupBy.

   A GroupedObservable is an observable type generated by Observable.groupBy. It has the following properties:

   - comes accompanied with a key property after which the grouping was made

   - supports a single subscriber, throwing IllegalStateException if you attempt multiple subscriptions

4. trait ObservableLike[+A, Self[+T] <: ObservableLike[T, Self]] extends Serializable

   

   Defines the available operations for observable-like instances.

5. final class RefCountObservable[+T] extends Observable[T]

   

   A RefCountObservable is an observable that wraps a ConnectableObservable, initiating the connection on the first subscribe() and then staying connected as long as there is at least one subscription active.