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:

Iterable<O>, Collection<O>, Queue<O>, Subscriber<I>, Subscription, Fuseable, Fuseable.QueueSubscription<O>, Producer, Receiver, Trackable

Enclosing class:

Operators

public static class Operators.MonoSubscriber<I,O>
extends Object
implements Subscriber<I>, Trackable, Receiver, Producer, Fuseable, 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).

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Fuseable

Fuseable.ConditionalSubscriber<T>, Fuseable.QueueSubscription<T>, Fuseable.ScalarCallable<T>, Fuseable.SynchronousSubscription<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected Subscriber<? super O>	actual
protected O	value

Fields inherited from interface reactor.core.Trackable

UNSPECIFIED

Fields inherited from interface reactor.core.Fuseable

ANY, ASYNC, NONE, SYNC, THREAD_BARRIER

Constructor Summary

Constructors

Constructor and Description
MonoSubscriber(Subscriber<? super O> actual)

Method Summary

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

actual

protected final Subscriber<? super O> actual

value

protected O value

Constructor Detail

MonoSubscriber

public MonoSubscriber(Subscriber<? super O> actual)

Method Detail

cancel

public void cancel()

Specified by:

cancel in interface Subscription

clear

public final void clear()

Specified by:

clear in interface Collection<O>

complete

public final void complete(O v)

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:

v - the value to emit

downstream

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

isCancelled

public final boolean isCancelled()

Returns true if this Subscription has been cancelled.

Specified by:

isCancelled in interface Trackable

Returns:

true if this Subscription has been cancelled

isEmpty

public final boolean isEmpty()

Specified by:

isEmpty in interface Collection<O>

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 void onComplete()

Specified by:

onComplete in interface Subscriber<I>

onError

public void onError(Throwable t)

Specified by:

onError in interface Subscriber<I>

onNext

public void onNext(I t)

Specified by:

onNext in interface Subscriber<I>

onSubscribe

public void onSubscribe(Subscription s)

Specified by:

onSubscribe in interface Subscriber<I>

poll

public final O poll()

Specified by:

poll in interface Queue<O>

request

public void request(long n)

Specified by:

request in interface Subscription

requestFusion

public int requestFusion(int mode)

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:

mode - the mode to request

Returns:

the fusion mode activated

setValue

public void setValue(O value)

size

public int size()

Specified by:

size in interface Collection<O>

upstream

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