| io.reactivex.ObservableSource<T> |
Known Indirect Subclasses
| AsyncSubject<T> |
An Subject that emits the very last value followed by a completion event or the received error to Observers. |
| BehaviorSubject<T> |
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed
Observer. |
| ConnectableObservable<T> |
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. |
| GroupedObservable<K, T> |
An Observable that has been grouped by key, the value of which can be obtained with getKey(). |
| Observable<T> |
The Observable class is the non-backpressured, optionally multi-valued base reactive class that
offers factory methods, intermediate operators and the ability to consume synchronous
and/or asynchronous reactive dataflows. |
| PublishSubject<T> |
Subject that, once an Observer has subscribed, emits all subsequently observed items to the
subscriber. |
| ReplaySubject<T> |
Replays events to Observers. |
| Subject<T> |
Represents an Observer and an Observable at the same time, allowing
multicasting events from a single source to multiple child Subscribers. |
| UnicastSubject<T> |
Subject that allows only a single Subscriber to subscribe to it during its lifetime. |
|
Class Overview
Represents a basic, non-backpressured Observable source base interface,
consumable via an Observer.
Summary
| Public Methods |
|
abstract
void
|
subscribe(Observer<? super T> observer)
Subscribes the given Observer to this ObservableSource instance.
|
Public Methods
public
abstract
void
subscribe
(Observer<? super T> observer)
Subscribes the given Observer to this ObservableSource instance.
Parameters
| observer |
the Observer, not null |