T - the upstream value typeR - the downstream parameter typepublic final class PublisherLift<R,T>
extends java.lang.Object
implements org.reactivestreams.Publisher<R>
By having a concrete Publisher as lift, operator fusing can now identify both the source and the operation inside it via casting, unlike the lambda version of this.
| Constructor and Description |
|---|
PublisherLift(org.reactivestreams.Publisher<? extends T> source,
Observable.Operator<? extends R,? super T> operator) |
| Modifier and Type | Method and Description |
|---|---|
Observable.Operator<? extends R,? super T> |
operator()
Returns the operator of this lift publisher.
|
org.reactivestreams.Publisher<? extends T> |
source()
Returns the source of this lift publisher.
|
void |
subscribe(org.reactivestreams.Subscriber<? super R> s) |
public PublisherLift(org.reactivestreams.Publisher<? extends T> source, Observable.Operator<? extends R,? super T> operator)
public Observable.Operator<? extends R,? super T> operator()
public org.reactivestreams.Publisher<? extends T> source()