reactor.rx.action.combination

Class FanInAction.InnerSubscriber<I,E,O>

java.lang.Object

reactor.rx.action.combination.FanInAction.InnerSubscriber<I,E,O>

All Implemented Interfaces:

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

Direct Known Subclasses:

CombineLatestAction.InnerSubscriber, MergeAction.InnerSubscriber, ZipAction.InnerSubscriber

Enclosing class:

FanInAction<I,E,O,SUBSCRIBER extends FanInAction.InnerSubscriber<I,E,O>>

public abstract static class FanInAction.InnerSubscriber<I,E,O>
extends Object
implements org.reactivestreams.Subscriber<I>, NonBlocking, Consumer<Long>

Method Summary

Modifier and Type	Method and Description
void	accept(Long pendingRequests) Execute the logic of the action, accepting the given parameter.
void	cancel()
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	onError(Throwable t)
void	request(long n)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Subscriber

onNext, onSubscribe

Method Detail

cancel

public void cancel()

accept

public void accept(Long pendingRequests)

Description copied from interface: Consumer

Execute the logic of the action, accepting the given parameter.

Specified by:

accept in interface Consumer<Long>

Parameters:

pendingRequests - The parameter to pass to the consumer.

request

public void request(long n)

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<I>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<I>

isReactivePull

public boolean isReactivePull(Dispatcher dispatcher,
                              long producerCapacity)

Description copied from interface: NonBlocking

Get the assigned Dispatcher.

Specified by:

isReactivePull in interface NonBlocking

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

Returns:

long capacity

toString

public String toString()

Overrides:

toString in class Object