reactor.core.publisher

Class Operators.DeferredSubscription

java.lang.Object

reactor.core.publisher.Operators.DeferredSubscription

All Implemented Interfaces:

org.reactivestreams.Subscription, Receiver, Trackable

Enclosing class:

Operators

public static class Operators.DeferredSubscription
extends java.lang.Object
implements org.reactivestreams.Subscription, Receiver, Trackable

Base class for Subscribers that will receive their Subscriptions at any time yet they need to be cancelled or requested at any time.

Field Summary

Fields inherited from interface reactor.core.Trackable

UNSPECIFIED

Constructor Summary

Constructors

Constructor and Description
DeferredSubscription()

Method Summary

Modifier and Type	Method and Description
void	cancel()
boolean	isCancelled() Returns true if this arbiter has been cancelled.
boolean	isStarted() Has this upstream started or "onSubscribed" ?
boolean	isTerminated() Has this upstream finished or "completed" / "failed" ?
void	request(long n)
long	requestedFromDownstream() Return defined element capacity, used to drive new Subscription request needs.
boolean	set(org.reactivestreams.Subscription s) Atomically sets the single subscription and requests the missed amount from it.
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, toString, wait, wait, wait

Methods inherited from interface reactor.core.Trackable

expectedFromUpstream, getCapacity, getError, getPending, limit

Constructor Detail

DeferredSubscription

public DeferredSubscription()

Method Detail

set

public final boolean set(org.reactivestreams.Subscription s)

Atomically sets the single subscription and requests the missed amount from it.

Parameters:

s - the subscription to set

Returns:

false if this arbiter is cancelled or there was a subscription already set

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

isCancelled

public final boolean isCancelled()

Returns true if this arbiter has been cancelled.

Specified by:

isCancelled in interface Trackable

Returns:

true if this arbiter has been cancelled

isStarted

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

requestedFromDownstream

public final long requestedFromDownstream()

Description copied from interface: Trackable

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:

requestedFromDownstream in interface Trackable

Returns:

long capacity

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.