Signal (reactor-core 3.3.10.RELEASE)

Type Parameters:

T - the value type

All Superinterfaces:

Consumer<Subscriber<? super T>>, Supplier<T>
```
public interface Signal<T>
extends Supplier<T>, Consumer<Subscriber<? super T>>
```
A domain representation of a Reactive Stream signal. There are 4 distinct signals and their possible sequence is defined as such: onError | (onSubscribe onNext* (onError | onComplete)?)

Author:

Stephane Maldini

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method and Description
`default void`	`accept(Subscriber<? super T> observer)` Propagate the signal represented by this `Signal` instance to a given `Subscriber`.
`static <T> Signal<T>`	`complete()` Creates and returns a `Signal` of variety `Type.COMPLETE`.
`static <T> Signal<T>`	`complete(Context context)` Creates and returns a `Signal` of variety `Type.COMPLETE`, associated with a specific `Context`.
`static <T> Signal<T>`	`error(Throwable e)` Creates and returns a `Signal` of variety `Type.FAILED`, which holds the error.
`static <T> Signal<T>`	`error(Throwable e, Context context)` Creates and returns a `Signal` of variety `Type.FAILED`, which holds the error and the `Context` associated with the erroring source.
`T`	`get()` Retrieves the item associated with this (onNext) signal.
`Context`	`getContext()` Return the `Context` that is accessible by the time this `Signal` was emitted.
`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`
`default boolean`	`hasError()` Read whether this signal is on error and carries the cause.
`default boolean`	`hasValue()` Has this signal an item associated with it ? (which only happens if it is an (onNext) signal)
`static boolean`	`isComplete(Object o)` Check if an arbitrary Object represents a COMPLETE `Signal`.
`static boolean`	`isError(Object o)` Check if a arbitrary Object represents an ERROR `Signal`.
`default boolean`	`isOnComplete()` Indicates whether this signal represents an `onComplete` event.
`default boolean`	`isOnError()` Indicates whether this signal represents an `onError` event.
`default boolean`	`isOnNext()` Indicates whether this signal represents an `onNext` event.
`default boolean`	`isOnSubscribe()` Indicates whether this signal represents an `onSubscribe` event.
`static <T> Signal<T>`	`next(T t)` Creates and returns a `Signal` of variety `Type.NEXT`, which holds the value.
`static <T> Signal<T>`	`next(T t, Context context)` Creates and returns a `Signal` of variety `Type.NEXT`, which holds the value and the `Context` associated with the emitting source.
`static <T> Signal<T>`	`subscribe(Subscription subscription)` Creates and returns a `Signal` of variety `Type.ON_SUBSCRIBE`.
`static <T> Signal<T>`	`subscribe(Subscription subscription, Context context)` Creates and returns a `Signal` of variety `Type.ON_SUBSCRIBE`, that holds the `Context` associated with the subscribed source.

Methods inherited from interface java.util.function.Consumer
andThen

- Method Detail
  - accept
```
default void accept(Subscriber<? super T> observer)
```
    Propagate the signal represented by this Signal instance to a given Subscriber.
    
    Specified by:
    
    accept in interface Consumer<Subscriber<? super T>>
    
    Parameters:
    
    observer - the Subscriber to play the Signal on
  - complete
```
static <T> Signal<T> complete()
```
    Creates and returns a Signal of variety Type.COMPLETE.
    Note that this variant associates an empty Context with the Signal.
    
    Type Parameters:
    
    T - the value type
    
    Returns:
    
    an OnCompleted variety of Signal
  - complete
```
static <T> Signal<T> complete(Context context)
```
    Creates and returns a Signal of variety Type.COMPLETE, associated with a specific Context.
    
    Type Parameters:
    
    T - the value type
    
    Parameters:
    
    context - the Context associated with the completing source.
    
    Returns:
    
    an OnCompleted variety of Signal
  - error
```
static <T> Signal<T> error(Throwable e)
```
    Creates and returns a Signal of variety Type.FAILED, which holds the error.
    Note that this variant associates an empty Context with the Signal.
    
    Type Parameters:
    
    T - the value type
    
    Parameters:
    
    e - the error associated to the signal
    
    Returns:
    
    an OnError variety of Signal
  - error
```
static <T> Signal<T> error(Throwable e,
                           Context context)
```
    Creates and returns a Signal of variety Type.FAILED, which holds the error and the Context associated with the erroring source.
    
    Type Parameters:
    
    T - the value type
    
    Parameters:
    
    e - the error associated to the signal
    
    context - the Context associated with the erroring source
    
    Returns:
    
    an OnError variety of Signal
  - get
```
@Nullable
T get()
```
    Retrieves the item associated with this (onNext) signal.
    
    Specified by:
    
    get in interface Supplier<T>
    
    Returns:
    
    the item associated with this (onNext) signal, or null if not relevant
  - getContext
```
Context getContext()
```
    Return the Context that is accessible by the time this Signal was emitted.
    
    Returns:
    
    the Context, or an empty one if no context is available.
  - getSubscription
```
@Nullable
Subscription getSubscription()
```
    Read the subscription associated with this (onSubscribe) signal.
    
    Returns:
    
    the Subscription associated with this (onSubscribe) signal, or null if not relevant
  - getThrowable
```
@Nullable
Throwable getThrowable()
```
    Read the error associated with this (onError) signal.
    
    Returns:
    
    the Throwable associated with this (onError) signal, or null if not relevant
  - getType
```
SignalType getType()
```
    Read the type of this signal: SignalType.ON_SUBSCRIBE, SignalType.ON_NEXT, SignalType.ON_ERROR, or SignalType.ON_COMPLETE
    
    Returns:
    
    the type of the signal
  - hasError
```
default boolean hasError()
```
    Read whether this signal is on error and carries the cause.
    
    Returns:
    
    a boolean indicating whether this signal has an error
  - hasValue
```
default boolean hasValue()
```
    Has this signal an item associated with it ? (which only happens if it is an (onNext) signal)
    
    Returns:
    
    a boolean indicating whether or not this signal has an item associated with it
  - isComplete
```
static boolean isComplete(Object o)
```
    Check if an arbitrary Object represents a COMPLETE Signal.
    
    Parameters:
    
    o - the object to check
    
    Returns:
    
    true if object represents the completion signal
  - isError
```
static boolean isError(Object o)
```
    Check if a arbitrary Object represents an ERROR Signal.
    
    Parameters:
    
    o - the object to check
    
    Returns:
    
    true if object represents the error signal
  - isOnComplete
```
default boolean isOnComplete()
```
    Indicates whether this signal represents an onComplete event.
    
    Returns:
    
    a boolean indicating whether this signal represents an onSubscribe event
  - isOnError
```
default boolean isOnError()
```
    Indicates whether this signal represents an onError event.
    
    Returns:
    
    a boolean indicating whether this signal represents an onError event
  - isOnNext
```
default boolean isOnNext()
```
    Indicates whether this signal represents an onNext event.
    
    Returns:
    
    a boolean indicating whether this signal represents an onNext event
  - isOnSubscribe
```
default boolean isOnSubscribe()
```
    Indicates whether this signal represents an onSubscribe event.
    
    Returns:
    
    a boolean indicating whether this signal represents an onSubscribe event
  - next
```
static <T> Signal<T> next(T t)
```
    Creates and returns a Signal of variety Type.NEXT, which holds the value.
    Note that this variant associates an empty Context with the Signal.
    
    Type Parameters:
    
    T - the value type
    
    Parameters:
    
    t - the value item associated to the signal
    
    Returns:
    
    an OnNext variety of Signal
  - next
```
static <T> Signal<T> next(T t,
                          Context context)
```
    Creates and returns a Signal of variety Type.NEXT, which holds the value and the Context associated with the emitting source.
    
    Type Parameters:
    
    T - the value type
    
    Parameters:
    
    t - the value item associated to the signal
    
    context - the Context associated with the emitting source
    
    Returns:
    
    an OnNext variety of Signal
  - subscribe
```
static <T> Signal<T> subscribe(Subscription subscription)
```
    Creates and returns a Signal of variety Type.ON_SUBSCRIBE.
    Note that this variant associates an empty Context with the Signal.
    
    Type Parameters:
    
    T - the value type
    
    Parameters:
    
    subscription - the subscription
    
    Returns:
    
    an OnSubscribe variety of Signal
  - subscribe
```
static <T> Signal<T> subscribe(Subscription subscription,
                               Context context)
```
    Creates and returns a Signal of variety Type.ON_SUBSCRIBE, that holds the Context associated with the subscribed source.
    
    Type Parameters:
    
    T - the value type
    
    Parameters:
    
    subscription - the subscription
    
    context - the Context associated with the subscribed source
    
    Returns:
    
    an OnSubscribe variety of Signal

Interface Signal<T>

Method Summary

Methods inherited from interface java.util.function.Consumer

Method Detail

accept

complete

complete

error

error

get

getContext

getSubscription

getThrowable

getType

hasError

hasValue

isComplete

isError

isOnComplete

isOnError

isOnNext

isOnSubscribe

next

next

subscribe

subscribe