hu.akarnokd.rxjava2.internal.operators.nbp

Class NbpOnSubscribeLift<R,T>

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.nbp.NbpOnSubscribeLift<R,T>

Type Parameters:

T - the upstream value type

R - the downstream parameter type

All Implemented Interfaces:

Consumer<NbpObservable.NbpSubscriber<? super R>>, NbpObservable.NbpOnSubscribe<R>

public final class NbpOnSubscribeLift<R,T>
extends java.lang.Object
implements NbpObservable.NbpOnSubscribe<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
NbpOnSubscribeLift(NbpObservable<? extends T> source, NbpObservable.NbpOperator<? extends R,? super T> operator)

Method Summary

Modifier and Type	Method and Description
void	accept(NbpObservable.NbpSubscriber<? super R> s)
NbpObservable.NbpOperator<? extends R,? super T>	operator() Returns the operator of this lift publisher.
NbpObservable<? extends T>	source() Returns the source of this lift publisher.

Methods inherited from class java.lang.Object

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

Constructor Detail

NbpOnSubscribeLift

public NbpOnSubscribeLift(NbpObservable<? extends T> source,
                          NbpObservable.NbpOperator<? extends R,? super T> operator)

Method Detail

operator

public NbpObservable.NbpOperator<? extends R,? super T> operator()

Returns the operator of this lift publisher.

Returns:

the operator of this lift publisher

source

public NbpObservable<? extends T> source()

Returns the source of this lift publisher.

Returns:

the source of this lift publisher

accept

public void accept(NbpObservable.NbpSubscriber<? super R> s)

Specified by:

accept in interface Consumer<NbpObservable.NbpSubscriber<? super R>>