Emitted by Observables returned by rx.lang.scala.Observable.materialize.
The Observable interface that implements the Reactive Pattern.
Placeholder for extension methods into Observable[T] from other types
Provides a mechanism for receiving push-based notifications.
Represents an object that schedules units of work.
A Subject is an Observable and an Observer at the same time.
Subscriptions are returned from all
Observable.subscribe methods to allow unsubscribing.
These function conversions convert between Scala functions and Rx
These functions convert between RxScala types RxJava types.
Provides pattern matching support and constructors for Notifications.
Provides various ways to construct new Observables.
Subject that, once an
Observer has subscribed, emits all subsequently observed items to the
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()
Contains special Observables.
Subjects are Observers and Observables at the same time.