reactor.rx.action.combination

Class SwitchAction.SwitchSubscriber

java.lang.Object

reactor.rx.action.combination.SwitchAction.SwitchSubscriber

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription, NonBlocking

Enclosing class:

SwitchAction<T>

public class SwitchAction.SwitchSubscriber
extends Object
implements NonBlocking, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Constructor Summary

Constructors

Constructor and Description
SwitchSubscriber(org.reactivestreams.Publisher<? extends T> publisher)

Method Summary

Modifier and Type	Method and Description
void	cancel()
long	getCapacity() Return defined element capacity, used to drive new Subscription request needs.
org.reactivestreams.Subscription	getSubscription()
boolean	isReactivePull(Dispatcher dispatcher, long producerCapacity) Get the assigned Dispatcher.
void	onComplete()
void	onError(Throwable t)
void	onNext(T t)
void	onSubscribe(org.reactivestreams.Subscription s)
void	request(long n)

Methods inherited from class java.lang.Object

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

Constructor Detail

SwitchSubscriber

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

Method Detail

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

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

onNext

public void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

getSubscription

public org.reactivestreams.Subscription getSubscription()