reactor.rx.action.combination

Class CombineLatestAction.InnerSubscriber<O,V>

java.lang.Object

reactor.rx.action.combination.FanInAction.InnerSubscriber<O,CombineLatestAction.Zippable<O>,V>

reactor.rx.action.combination.CombineLatestAction.InnerSubscriber<O,V>

All Implemented Interfaces:

org.reactivestreams.Subscriber<O>, NonBlocking, Consumer<Long>

Enclosing class:

CombineLatestAction<O,V,TUPLE extends Tuple>

public static final class CombineLatestAction.InnerSubscriber<O,V>
extends FanInAction.InnerSubscriber<O,CombineLatestAction.Zippable<O>,V>

Method Summary

Modifier and Type	Method and Description
boolean	isReactivePull(Dispatcher dispatcher, long producerCapacity) Get the assigned Dispatcher.
void	onNext(O ev)
void	onSubscribe(org.reactivestreams.Subscription subscription)
String	toString()

Methods inherited from class reactor.rx.action.combination.FanInAction.InnerSubscriber

accept, cancel, getCapacity, onComplete, onError, request

Methods inherited from class java.lang.Object

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

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

onNext

public void onNext(O ev)

isReactivePull

public boolean isReactivePull(Dispatcher dispatcher,
                              long producerCapacity)

Description copied from interface: NonBlocking

Get the assigned Dispatcher.

Specified by:

isReactivePull in interface NonBlocking

Overrides:

isReactivePull in class FanInAction.InnerSubscriber<O,CombineLatestAction.Zippable<O>,V>

Returns:

true if the component wishes to use a back-pressure ready message-passing (e.g., ReactiveSubscription)

toString

public String toString()

Overrides:

toString in class FanInAction.InnerSubscriber<O,CombineLatestAction.Zippable<O>,V>