reactor.rx.action.combination

Class ZipAction.InnerSubscriber<O,V>

java.lang.Object

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

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

All Implemented Interfaces:

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

Enclosing class:

ZipAction<O,V,TUPLE extends Tuple>

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

Method Summary

Modifier and Type	Method and Description
long	getCapacity() Return defined element capacity, used to drive new Subscription request needs.
boolean	isReactivePull(Dispatcher dispatcher, long producerCapacity) Get the assigned Dispatcher.
void	onComplete()
void	onNext(O ev)
void	onSubscribe(org.reactivestreams.Subscription subscription)
void	request(long n)
String	toString()

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

accept, cancel, onError

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)

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<O>

Overrides:

onComplete in class FanInAction.InnerSubscriber<O,ZipAction.Zippable<O>,V>

request

public void request(long n)

Overrides:

request in class FanInAction.InnerSubscriber<O,ZipAction.Zippable<O>,V>

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,ZipAction.Zippable<O>,V>

Returns:

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

getCapacity

public long getCapacity()

Description copied from interface: NonBlocking

Return defined element capacity, used to drive new Subscription request needs. This is the maximum in-flight data allowed to transit to this elements.

Specified by:

getCapacity in interface NonBlocking

Overrides:

getCapacity in class FanInAction.InnerSubscriber<O,ZipAction.Zippable<O>,V>

Returns:

long capacity

toString

public String toString()

Overrides:

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