Package

rx.lang.scala

observables

Permalink

package 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 a GroupedObservable and a ConnectableObservable, but these are not needed in Scala, because we use a pair (key, observable) instead of GroupedObservable and a pair (startFunction, observable) instead of ConnectableObservable.

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. observables
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. final class BlockingObservable[+T] extends AnyVal

    Permalink

    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

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

    Permalink

    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.

  3. final class ErrorDelayingObservable[+T] extends AnyVal

    Permalink

    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.

    Annotations
    @Experimental()

Inherited from AnyRef

Inherited from Any

Ungrouped