reactor.core

Interface Trackable

All Known Implementing Classes:

BlockingSink, DirectProcessor, EmitterProcessor, FluxProcessor, MonoProcessor, Operators.DeferredSubscription, Operators.MonoSubscriber, Operators.SubscriberAdapter, ReplayProcessor, TopicProcessor, UnicastProcessor, WorkQueueProcessor

public interface Trackable

A lifecycle backed downstream

Field Summary

Fields

Modifier and Type	Field and Description
static long	UNSPECIFIED Returned value when a given component does not provide access to the requested trait

Method Summary

Modifier and Type	Method and Description
default long	expectedFromUpstream()
default long	getCapacity() Return defined element capacity
default java.lang.Throwable	getError() Current error if any, default to null
default long	getPending() Return current used space in buffer
default boolean	isCancelled()
default boolean	isStarted() Has this upstream started or "onSubscribed" ?
default boolean	isTerminated() Has this upstream finished or "completed" / "failed" ?
default long	limit()
default long	requestedFromDownstream() Return defined element capacity, used to drive new Subscription request needs.

Field Detail

UNSPECIFIED

static final long UNSPECIFIED

Returned value when a given component does not provide access to the requested trait

See Also:

Constant Field Values

Method Detail

expectedFromUpstream

default long expectedFromUpstream()

Returns:

expected number of events to be produced to this component

getCapacity

default long getCapacity()

Return defined element capacity

Returns:

long capacity

getError

default java.lang.Throwable getError()

Current error if any, default to null

Returns:

Current error if any, default to null

getPending

default long getPending()

Return current used space in buffer

Returns:

long capacity

isCancelled

default boolean isCancelled()

Returns:

has the downstream "cancelled" and interrupted its consuming ?

isStarted

default boolean isStarted()

Has this upstream started or "onSubscribed" ?

Returns:

has this upstream started or "onSubscribed" ?

isTerminated

default boolean isTerminated()

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

Returns:

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

limit

default long limit()

Returns:

a given limit threshold to replenish outstanding upstream request

requestedFromDownstream

default long requestedFromDownstream()

Return defined element capacity, used to drive new Subscription request needs. This is the maximum in-flight data allowed to transit to this elements.

Returns:

long capacity