p

rxscalajs

package rxscalajs

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class ConnectableObservable [+T] extends AnyRef
  2. class Notification [T] extends Object
    Annotations
    @RawJSType() @native() @JSImport( "rxjs/Rx" , "Notification" , "Rx.Notification" )
  3. class Observable [+T] extends AnyRef

    The Observable interface that implements the Reactive Pattern.

  4. trait Observer [-T] extends AnyRef

    Provides a mechanism for receiving push-based notifications.

    Provides a mechanism for receiving push-based notifications.

    After an Observer calls an rxscalajs.Observable's subscribe method, the Observable calls the Observer's onNext method to provide notifications. A well-behaved Observable will call an Observer's onCompleted or onError methods exactly once.

  5. trait Scheduler extends Object
    Annotations
    @RawJSType() @native()
  6. class Subject [T] extends Observable[T] with Observer[T]

    A Subject is an Observable and an Observer at the same time.

Value Members

  1. object Notification extends Object
    Annotations
    @native() @JSImport( "rxjs/Rx" , "Notification" , "Rx.Notification" )
  2. object Observable extends ObservableInstances
  3. object Scheduler extends Object
    Annotations
    @native() @JSImport( "rxjs/Rx" , "Scheduler" , "Rx.Scheduler" )
  4. object Subject

    Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.

    Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.

    Example: 

    1. val subject = Subject[String]()
// observer1 will receive all onNext and onCompleted events
subject.subscribe(observer1)
subject.onNext("one")
subject.onNext("two")
// observer2 will only receive "three" and onCompleted
subject.subscribe(observer2)
subject.onNext("three")
subject.onCompleted()

Ungrouped