reactor.core.publisher

Class Operators.SubscriberAdapter<I,O>

java.lang.Object

reactor.core.publisher.Operators.SubscriberAdapter<I,O>

Type Parameters:

I - the input value type

O - the output value type

All Implemented Interfaces:

Subscriber<I>, Subscription, Producer, Receiver, Trackable

Enclosing class:

Operators

public static class Operators.SubscriberAdapter<I,O>
extends Object
implements Subscriber<I>, Subscription, Trackable, Receiver, Producer

A Subscriber with an asymetric typed wrapped subscriber. Yet it represents a unique relationship between a Publisher and a Subscriber, it doesn't implement the Processor interface allowing multiple subscribes.

Field Summary

Fields

Modifier and Type	Field and Description
protected Subscriber<? super O>	subscriber
protected Subscription	subscription

Fields inherited from interface reactor.core.Trackable

UNSPECIFIED

Constructor Summary

Constructors

Constructor and Description
SubscriberAdapter(Subscriber<? super O> subscriber)

Method Summary

Modifier and Type	Method and Description
void	cancel()
protected void	doCancel()
protected void	doComplete()
protected void	doError(Throwable throwable)
protected void	doNext(I i)
protected void	doOnSubscribe(Subscription subscription) Hook for further processing of onSubscribe's Subscription.
protected void	doOnSubscriberError(Throwable throwable)
protected void	doRequest(long n)
Subscriber<? super O>	downstream() Return the direct data receiver.
long	getCapacity() Return defined element capacity
long	getPending() Return current used space in buffer
boolean	isStarted() Has this upstream started or "onSubscribed" ?
boolean	isTerminated() Has this upstream finished or "completed" / "failed" ?
void	onComplete()
void	onError(Throwable t)
void	onNext(I i)
void	onSubscribe(Subscription s)
void	request(long n)
String	toString()
Subscription	upstream() Return the direct source of data, Supports reference.

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.core.Trackable

expectedFromUpstream, getError, isCancelled, limit, requestedFromDownstream

Field Detail

subscriber

protected final Subscriber<? super O> subscriber

subscription

protected Subscription subscription

Constructor Detail

SubscriberAdapter

public SubscriberAdapter(Subscriber<? super O> subscriber)

Method Detail

cancel

public final void cancel()

Specified by:

cancel in interface Subscription

downstream

public Subscriber<? super O> downstream()

Description copied from interface: Producer

Return the direct data receiver.

Specified by:

downstream in interface Producer

Returns:

the direct data receiver

getCapacity

public long getCapacity()

Description copied from interface: Trackable

Return defined element capacity

Specified by:

getCapacity in interface Trackable

Returns:

long capacity

getPending

public long getPending()

Description copied from interface: Trackable

Return current used space in buffer

Specified by:

getPending in interface Trackable

Returns:

long capacity

isStarted

public boolean isStarted()

Description copied from interface: Trackable

Has this upstream started or "onSubscribed" ?

Specified by:

isStarted in interface Trackable

Returns:

has this upstream started or "onSubscribed" ?

isTerminated

public boolean isTerminated()

Description copied from interface: Trackable

Has this upstream finished or "completed" / "failed" ?

Specified by:

isTerminated in interface Trackable

Returns:

has this upstream finished or "completed" / "failed" ?

onComplete

public final void onComplete()

Specified by:

onComplete in interface Subscriber<I>

onError

public final void onError(Throwable t)

Specified by:

onError in interface Subscriber<I>

onNext

public final void onNext(I i)

Specified by:

onNext in interface Subscriber<I>

onSubscribe

public final void onSubscribe(Subscription s)

Specified by:

onSubscribe in interface Subscriber<I>

request

public final void request(long n)

Specified by:

request in interface Subscription

toString

public String toString()

Overrides:

toString in class Object

upstream

public Subscription upstream()

Description copied from interface: Receiver

Return the direct source of data, Supports reference.

Specified by:

upstream in interface Receiver

Returns:

the direct source of data, Supports reference.

doOnSubscribe

protected void doOnSubscribe(Subscription subscription)

Hook for further processing of onSubscribe's Subscription.

Parameters:

subscription - the subscription to optionally process

doNext

protected void doNext(I i)

doError

protected void doError(Throwable throwable)

doOnSubscriberError

protected void doOnSubscriberError(Throwable throwable)

doComplete

protected void doComplete()

doRequest

protected void doRequest(long n)

doCancel

protected void doCancel()