reactor.core.publisher

Class Operators.MonoSubscriber<I,O>

java.lang.Object

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

Type Parameters:

I - The upstream sequence type

O - The downstream sequence type

All Implemented Interfaces:

java.lang.Iterable<O>, java.util.Collection<O>, java.util.Queue<O>, org.reactivestreams.Subscriber<I>, org.reactivestreams.Subscription, Fuseable.QueueSubscription<O>, Loopback, Producer, Receiver, Trackable

Enclosing class:

Operators

public static class Operators.MonoSubscriber<I,O>
extends java.lang.Object
implements org.reactivestreams.Subscriber<I>, Loopback, Trackable, Receiver, Producer, Fuseable.QueueSubscription<O>

A Subscriber/Subscription barrier that holds a single value at most and properly gates asynchronous behaviors resulting from concurrent request or cancel and onXXX signals. Publisher Operators using this Subscriber can be fused (implement Fuseable).

Field Summary

Fields

Modifier and Type	Field and Description
protected byte	outputFused
protected org.reactivestreams.Subscriber<? super O>	subscriber
protected O	value

Fields inherited from interface reactor.core.Trackable

UNSPECIFIED

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	clear()
void	complete(O value) Tries to emit the value and complete the underlying subscriber or stores the value away until there is a request for it.
java.lang.Object	connectedOutput()
org.reactivestreams.Subscriber<? super O>	downstream() Return the direct data receiver.
boolean	isCancelled()
boolean	isEmpty()
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 t)
void	onSubscribe(org.reactivestreams.Subscription s)
O	poll()
void	request(long n)
int	requestFusion(int requestedMode) Request a specific fusion mode from this QueueSubscription.
void	setValue(O value)
int	size()
java.lang.Object	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.Loopback

connectedInput

Methods inherited from interface reactor.core.Trackable

expectedFromUpstream, getCapacity, getError, getPending, limit, requestedFromDownstream

Methods inherited from interface reactor.core.Fuseable.QueueSubscription

add, addAll, contains, containsAll, element, iterator, offer, peek, remove, remove, removeAll, retainAll, toArray, toArray

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

subscriber

protected final org.reactivestreams.Subscriber<? super O> subscriber

value

protected O value

outputFused

protected byte outputFused

Constructor Detail

MonoSubscriber

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

Method Detail

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

onNext

public void onNext(I t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<I>

onError

public void onError(java.lang.Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<I>

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<I>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<I>

isCancelled

public final boolean isCancelled()

Specified by:

isCancelled in interface Trackable

Returns:

has the downstream "cancelled" and interrupted its consuming ?

downstream

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

setValue

public void setValue(O value)

complete

public final void complete(O value)

Tries to emit the value and complete the underlying subscriber or stores the value away until there is a request for it.

Make sure this method is called at most once

Parameters:

value - the value to emit

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

connectedOutput

public java.lang.Object connectedOutput()

Specified by:

connectedOutput in interface Loopback

Returns:

component delegated to for outgoing data or null if unavailable

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

upstream

public java.lang.Object 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.

requestFusion

public int requestFusion(int requestedMode)

Description copied from interface: Fuseable.QueueSubscription

Request a specific fusion mode from this QueueSubscription.

One should request either SYNC, ASYNC or ANY modes (never NONE) and the implementor should return NONE, SYNC or ASYNC (never ANY).

For example, if a source supports only ASYNC fusion but the intermediate operator supports only SYNC fuseable sources, the operator may request SYNC fusion and the source can reject it via NONE, thus the operator can return NONE as well to dowstream and the fusion doesn't happen.

Specified by:

requestFusion in interface Fuseable.QueueSubscription<O>

Parameters:

requestedMode - the mode to request

Returns:

the fusion mode activated

poll

public O poll()

Specified by:

poll in interface java.util.Queue<O>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface java.util.Collection<O>

clear

public void clear()

Specified by:

clear in interface java.util.Collection<O>

size

public int size()

Specified by:

size in interface java.util.Collection<O>