reactor.core.publisher

Class MutableNextSignal<T>

java.lang.Object

reactor.core.publisher.Signal<T>

reactor.core.publisher.MutableNextSignal<T>

All Implemented Interfaces:

Consumer<Subscriber<? super T>>, Supplier<T>

public class MutableNextSignal<T>
extends Signal<T>

A Signal flavour that is dedicated to the ON_NEXT signal type and is mutable, allowing to minimize the number of Signal instances created.

Note this implementation is not serializable, and is for advanced usage. Instances returned by the factory methods of Signal should usually be used instead.

Author:

Simon Baslé

Method Summary

Modifier and Type	Method and Description
T	get() Retrieves the item associated with this (onNext) signal.
Subscription	getSubscription() Read the subscription associated with this (onSubscribe) signal.
Throwable	getThrowable() Read the error associated with this (onError) signal.
SignalType	getType() Read the type of this signal: SignalType.ON_SUBSCRIBE, SignalType.ON_NEXT, SignalType.ON_ERROR, or SignalType.ON_COMPLETE
Signal<T>	mutate(T newT) Mutate this Signal instance with a new value as an alternative to creating a new instance.
static <T> MutableNextSignal<T>	of(T value) Create a new MutableNextSignal with an initial value.
static <T> MutableNextSignal<T>	undefined() Create a new MutableNextSignal that hasn't had a value set yet.

Methods inherited from class reactor.core.publisher.Signal

accept, complete, equals, error, hasError, hashCode, hasValue, isComplete, isError, isOnComplete, isOnError, isOnNext, isOnSubscribe, next, subscribe, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.function.Consumer

andThen

Method Detail

undefined

public static <T> MutableNextSignal<T> undefined()

Create a new MutableNextSignal that hasn't had a value set yet.

Type Parameters:

T - the type of the onNext elements.

Returns:

a new mutable next Signal

of

public static <T> MutableNextSignal<T> of(T value)

Create a new MutableNextSignal with an initial value.

Type Parameters:

T - the type of the onNext elements.

Parameters:

value - the initial value.

Returns:

a new mutable next Signal

getThrowable

public Throwable getThrowable()

Description copied from class: Signal

Read the error associated with this (onError) signal.

Specified by:

getThrowable in class Signal<T>

Returns:

the Throwable associated with this (onError) signal, or null if not relevant

getSubscription

public Subscription getSubscription()

Description copied from class: Signal

Read the subscription associated with this (onSubscribe) signal.

Specified by:

getSubscription in class Signal<T>

Returns:

the Subscription associated with this (onSubscribe) signal, or null if not relevant

get

public T get()

Description copied from class: Signal

Retrieves the item associated with this (onNext) signal.

Specified by:

get in interface Supplier<T>

Specified by:

get in class Signal<T>

Returns:

the item associated with this (onNext) signal, or null if not relevant

getType

public SignalType getType()

Description copied from class: Signal

Read the type of this signal: SignalType.ON_SUBSCRIBE, SignalType.ON_NEXT, SignalType.ON_ERROR, or SignalType.ON_COMPLETE

Specified by:

getType in class Signal<T>

Returns:

the type of the signal

mutate

public Signal<T> mutate(T newT)

Mutate this Signal instance with a new value as an alternative to creating a new instance. The method returns this instance so it can be used in places where a new Signal would have been created.

Parameters:

newT - the new onNext value

Returns:

the mutated ON_NEXT signal