Signal (reactor-3)

类型参数:

T - the value type

所有超级接口:

java.util.function.Consumer<org.reactivestreams.Subscriber<? super T>>, java.util.function.Supplier<T>
```
public interface Signal<T>
extends java.util.function.Supplier<T>, java.util.function.Consumer<org.reactivestreams.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)?)

作者:

Stephane Maldini

方法概要

所有方法静态方法实例方法抽象方法默认方法
限定符和类型	方法和说明
`default void`	`accept(org.reactivestreams.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(java.lang.Throwable e)` Creates and returns a `Signal` of variety `Type.FAILED`, which holds the error.
`static <T> Signal<T>`	`error(java.lang.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.
`ContextView`	`getContextView()` Return the readonly `ContextView` that is accessible by the time this `Signal` was emitted.
`org.reactivestreams.Subscription`	`getSubscription()` Read the subscription associated with this (onSubscribe) signal.
`java.lang.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 ?
`static boolean`	`isComplete(java.lang.Object o)` Check if an arbitrary Object represents a COMPLETE `Signal`.
`static boolean`	`isError(java.lang.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(org.reactivestreams.Subscription subscription)` Creates and returns a `Signal` of variety `Type.ON_SUBSCRIBE`.
`static <T> Signal<T>`	`subscribe(org.reactivestreams.Subscription subscription, Context context)` Creates and returns a `Signal` of variety `Type.ON_SUBSCRIBE`, that holds the `Context` associated with the subscribed source.

从接口继承的方法 java.util.function.Consumer
andThen

- 方法详细资料
  - 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.
    
    类型参数:
    
    T - the value type
    
    返回:
    
    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.
    
    类型参数:
    
    T - the value type
    
    参数:
    
    context - the Context associated with the completing source.
    
    返回:
    
    an OnCompleted variety of Signal
  - error
```
static <T> Signal<T> error(java.lang.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.
    
    类型参数:
    
    T - the value type
    
    参数:
    
    e - the error associated to the signal
    
    返回:
    
    an OnError variety of Signal
  - error
```
static <T> Signal<T> error(java.lang.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 - the value type
    
    参数:
    
    e - the error associated to the signal
    
    context - the Context associated with the erroring source
    
    返回:
    
    an OnError variety of Signal
  - 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.
    
    类型参数:
    
    T - the value type
    
    参数:
    
    t - the value item associated to the signal
    
    返回:
    
    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.
    
    类型参数:
    
    T - the value type
    
    参数:
    
    t - the value item associated to the signal
    
    context - the Context associated with the emitting source
    
    返回:
    
    an OnNext variety of Signal
  - subscribe
```
static <T> Signal<T> subscribe(org.reactivestreams.Subscription subscription)
```
    Creates and returns a Signal of variety Type.ON_SUBSCRIBE.
    Note that this variant associates an empty Context with the Signal.
    
    类型参数:
    
    T - the value type
    
    参数:
    
    subscription - the subscription
    
    返回:
    
    an OnSubscribe variety of Signal
  - subscribe
```
static <T> Signal<T> subscribe(org.reactivestreams.Subscription subscription,
                               Context context)
```
    Creates and returns a Signal of variety Type.ON_SUBSCRIBE, that holds the Context associated with the subscribed source.
    
    类型参数:
    
    T - the value type
    
    参数:
    
    subscription - the subscription
    
    context - the Context associated with the subscribed source
    
    返回:
    
    an OnSubscribe variety of Signal
  - isComplete
```
static boolean isComplete(java.lang.Object o)
```
    Check if an arbitrary Object represents a COMPLETE Signal.
    
    参数:
    
    o - the object to check
    
    返回:
    
    true if object represents the completion signal
  - isError
```
static boolean isError(java.lang.Object o)
```
    Check if a arbitrary Object represents an ERROR Signal.
    
    参数:
    
    o - the object to check
    
    返回:
    
    true if object represents the error signal
  - getThrowable
```
@Nullable
java.lang.Throwable getThrowable()
```
    Read the error associated with this (onError) signal.
    
    返回:
    
    the Throwable associated with this (onError) signal, or null if not relevant
  - getSubscription
```
@Nullable
org.reactivestreams.Subscription getSubscription()
```
    Read the subscription associated with this (onSubscribe) signal.
    
    返回:
    
    the Subscription associated with this (onSubscribe) signal, or null if not relevant
  - get
```
@Nullable
T get()
```
    Retrieves the item associated with this (onNext) signal.
    
    指定者:
    
    get 在接口中 java.util.function.Supplier<T>
    
    返回:
    
    the item associated with this (onNext) signal, or null if not relevant
  - hasValue
```
default boolean hasValue()
```
    Has this signal an item associated with it ? (which only happens if it is an (onNext) signal)
    
    返回:
    
    a boolean indicating whether or not this signal has an item associated with it
  - hasError
```
default boolean hasError()
```
    Read whether this signal is on error and carries the cause.
    
    返回:
    
    a boolean indicating whether this signal has an error
  - getType
```
SignalType getType()
```
    Read the type of this signal: SignalType.ON_SUBSCRIBE, SignalType.ON_NEXT, SignalType.ON_ERROR, or SignalType.ON_COMPLETE
    
    返回:
    
    the type of the signal
  - getContextView
```
ContextView getContextView()
```
    Return the readonly ContextView that is accessible by the time this Signal was emitted.
    
    返回:
    
    a readonly ContextView, or an empty one if no context is available.
  - isOnError
```
default boolean isOnError()
```
    Indicates whether this signal represents an onError event.
    
    返回:
    
    a boolean indicating whether this signal represents an onError event
  - isOnComplete
```
default boolean isOnComplete()
```
    Indicates whether this signal represents an onComplete event.
    
    返回:
    
    a boolean indicating whether this signal represents an onComplete event
  - isOnSubscribe
```
default boolean isOnSubscribe()
```
    Indicates whether this signal represents an onSubscribe event.
    
    返回:
    
    a boolean indicating whether this signal represents an onSubscribe event
  - isOnNext
```
default boolean isOnNext()
```
    Indicates whether this signal represents an onNext event.
    
    返回:
    
    a boolean indicating whether this signal represents an onNext event
  - accept
```
default void accept(org.reactivestreams.Subscriber<? super T> observer)
```
    Propagate the signal represented by this Signal instance to a given Subscriber.
    
    指定者:
    
    accept 在接口中 java.util.function.Consumer<org.reactivestreams.Subscriber<? super T>>
    
    参数:
    
    observer - the Subscriber to play the Signal on

接口 Signal<T>

方法概要

从接口继承的方法 java.util.function.Consumer

方法详细资料

complete

complete

error

error

next

next

subscribe

subscribe

isComplete

isError

getThrowable

getSubscription

get

hasValue

hasError

getType

getContextView

isOnError

isOnComplete

isOnSubscribe

isOnNext

accept