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:

org.reactivestreams.Subscriber<I>, org.reactivestreams.Subscription, Producer, Receiver, Trackable

Enclosing class:

Operators

public static class Operators.SubscriberAdapter<I,O>
extends java.lang.Object
implements org.reactivestreams.Subscriber<I>, org.reactivestreams.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 org.reactivestreams.Subscriber<? super O>	subscriber
protected org.reactivestreams.Subscription	subscription

Fields inherited from interface reactor.core.Trackable

UNSPECIFIED

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	cancel()
protected void	doCancel()
protected void	doComplete()
protected void	doError(java.lang.Throwable throwable)
protected void	doNext(I i)
protected void	doOnSubscribe(org.reactivestreams.Subscription subscription) Hook for further processing of onSubscribe's Subscription.
protected void	doOnSubscriberError(java.lang.Throwable throwable)
protected void	doRequest(long n)
org.reactivestreams.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(java.lang.Throwable t)
void	onNext(I i)
void	onSubscribe(org.reactivestreams.Subscription s)
void	request(long n)
java.lang.String	toString()
org.reactivestreams.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 org.reactivestreams.Subscriber<? super O> subscriber

subscription

protected org.reactivestreams.Subscription subscription

Constructor Detail

SubscriberAdapter

public SubscriberAdapter(org.reactivestreams.Subscriber<? super O> subscriber)

Method Detail

upstream

public org.reactivestreams.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.

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" ?

downstream

public org.reactivestreams.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

onSubscribe

public final void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<I>

doOnSubscribe

protected void doOnSubscribe(org.reactivestreams.Subscription subscription)

Hook for further processing of onSubscribe's Subscription.

Parameters:

subscription - the subscription to optionally process

onNext

public final void onNext(I i)

Specified by:

onNext in interface org.reactivestreams.Subscriber<I>

doNext

protected void doNext(I i)

onError

public final void onError(java.lang.Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<I>

doError

protected void doError(java.lang.Throwable throwable)

doOnSubscriberError

protected void doOnSubscriberError(java.lang.Throwable throwable)

onComplete

public final void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<I>

doComplete

protected void doComplete()

request

public final void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

doRequest

protected void doRequest(long n)

cancel

public final void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

doCancel

protected void doCancel()

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" ?

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object