hu.akarnokd.rxjava2.internal.operators

Class PublisherLift<R,T>

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.PublisherLift<R,T>

Type Parameters:

T - the upstream value type

R - the downstream parameter type

All Implemented Interfaces:

org.reactivestreams.Publisher<R>

public final class PublisherLift<R,T>
extends java.lang.Object
implements org.reactivestreams.Publisher<R>

Allows lifting operators into a chain of Publishers.

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 Summary

Constructors

Constructor and Description
PublisherLift(org.reactivestreams.Publisher<? extends T> source, Observable.Operator<? extends R,? super T> operator)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PublisherLift

public PublisherLift(org.reactivestreams.Publisher<? extends T> source,
                     Observable.Operator<? extends R,? super T> operator)

Method Detail

operator

public Observable.Operator<? extends R,? super T> operator()

Returns the operator of this lift publisher.

Returns:

the operator of this lift publisher

source

public org.reactivestreams.Publisher<? extends T> source()

Returns the source of this lift publisher.

Returns:

the source of this lift publisher

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super R> s)

Specified by:

subscribe in interface org.reactivestreams.Publisher<R>