Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.operators.observable |
Modifier and Type | Method and Description |
---|---|
<R> Observable<R> |
Observable.lift(ObservableOperator<? extends R,? super T> lifter)
This method requires advanced knowledge about building operators, please consider
other standard composition methods first;
Returns an
Observable which, when subscribed to, invokes the apply(Observer) method
of the provided ObservableOperator for each individual downstream Observer and allows the
insertion of a custom operator by accessing the downstream's Observer during this subscription phase
and providing a new Observer , containing the custom operator's intended business logic, that will be
used in the subscription process going further upstream. |
Constructor and Description |
---|
ObservableLift(ObservableSource<T> source,
ObservableOperator<? extends R,? super T> operator) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.