observables
An Observable that provides blocking operators.
An Observable that provides blocking operators.
You can obtain a BlockingObservable from an Observable using rx.lang.scala.Observable.toBlocking
A ConnectableObservable resembles an ordinary Observable, except that it does not begin emitting items when it is subscribed to, but only when its connect method is called.
A ConnectableObservable resembles an ordinary Observable, except that it does not begin emitting items when it is subscribed to, but only when its connect method is called. In this way you can wait for all intended Subscribers to subscribe to the Observable before the Observable begins emitting items.
EXPERIMENTAL An Observable that provides operators which delay errors when composing multiple Observables.
EXPERIMENTAL An Observable that provides operators which delay errors when composing multiple Observables.
Contains special Observables.
In Scala, this package only contains rx.lang.scala.observables.BlockingObservable. In the corresponding Java package
rx.observables, there is also aGroupedObservableand aConnectableObservable, but these are not needed in Scala, because we use a pair(key, observable)instead ofGroupedObservableand a pair(startFunction, observable)instead ofConnectableObservable.