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 |