reactor.rx.action.support

Class DefaultSubscriber<O>

java.lang.Object

reactor.rx.action.support.DefaultSubscriber<O>

All Implemented Interfaces:

org.reactivestreams.Subscriber<O>, NonBlocking

public class DefaultSubscriber<O>
extends Object
implements org.reactivestreams.Subscriber<O>, NonBlocking

Author:

Stephane Maldini

Constructor Summary

Constructors

Constructor and Description
DefaultSubscriber()

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	onError(Throwable t)
void	onNext(O o)
void	onSubscribe(org.reactivestreams.Subscription s)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSubscriber

public DefaultSubscriber()

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<O>

onNext

public void onNext(O o)

Specified by:

onNext in interface org.reactivestreams.Subscriber<O>

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<O>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<O>

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