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] with LiftOperators1[T, ConnectableObservable]

   

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

   Useful for converting cold observables into hot observables and thus returned by Observable.multicast.

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

   

   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 LiftOperators1[+T, Self[+U] <: Observable[U]] extends AnyRef

   

   An interface to be extended in Observable types that want to preserve the return type when applying operators.

   An interface to be extended in Observable types that want to preserve the return type when applying operators. For example the result of ConnectableObservable.map is still a ConnectableObservable and this interface represents an utility to do just that.

5. trait LiftOperators2[I, +T, Self[A, +B] <: Observable[B]] extends AnyRef

   

   An interface to be extended in Observable types that want to preserve the return type when applying operators.

   An interface to be extended in Observable types that want to preserve the return type when applying operators. For example the result of Subject.map is still a Subject and this interface represents an utility to do just that.

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