Operators.MonoSubscriber (reactor-3)

java.lang.Object
- reactor.core.publisher.Operators.MonoSubscriber<I,O>

类型参数:

I - The upstream sequence type

O - The downstream sequence type

所有已实现的接口:

java.lang.Iterable<O>, java.util.Collection<O>, java.util.Queue<O>, org.reactivestreams.Subscription, Fuseable, Fuseable.QueueSubscription<O>

封闭类:

Operators
```
public static class Operators.MonoSubscriber<I,O>
extends java.lang.Object
implements 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.

嵌套类概要
- 从接口继承的嵌套类/接口 reactor.core.Scannable
  Scannable.Attr<T>
- 从接口继承的嵌套类/接口 reactor.core.Fuseable
  Fuseable.ConditionalSubscriber<T>, Fuseable.QueueSubscription<T>, Fuseable.ScalarCallable<T>, Fuseable.SynchronousSubscription<T>

字段概要
- 从接口继承的字段 reactor.core.Scannable
  OPERATOR_NAME_UNRELATED_WORDS_PATTERN
- 从接口继承的字段 reactor.core.Fuseable
  ANY, ASYNC, NONE, SYNC, THREAD_BARRIER
- 从接口继承的字段 reactor.core.Fuseable.QueueSubscription
  NOT_SUPPORTED_MESSAGE

构造器概要

构造器
构造器和说明

MonoSubscriber(CoreSubscriber<? super O> actual)

构造器
构造器和说明
`MonoSubscriber(CoreSubscriber<? super O> actual)`

方法概要

所有方法实例方法具体方法默认方法
限定符和类型	方法和说明
`CoreSubscriber<? super O>`	`actual()`
`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.
`default Context`	`currentContext()` Request a `Context` from dependent components which can include downstream operators during subscribing or a terminal `Subscriber`.
`boolean`	`isCancelled()` Returns true if this Subscription has been cancelled.
`boolean`	`isEmpty()`
`void`	`onComplete()`
`void`	`onError(java.lang.Throwable t)`
`void`	`onNext(I t)`
`void`	`onSubscribe(org.reactivestreams.Subscription s)` Implementors should initialize any state used by `Subscriber.onNext(Object)` before calling `Subscription.request(long)`.
`O`	`poll()`
`void`	`request(long n)`
`int`	`requestFusion(int mode)` Request a specific fusion mode from this QueueSubscription.
`java.lang.Object`	`scanUnsafe(Scannable.Attr key)` This method is used internally by components to define their key-value mappings in a single place.
`void`	`setValue(O value)` Set the value internally, without impacting request tracking state.
`int`	`size()`

从类继承的方法 java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 reactor.core.Scannable
actuals, from, inners, isScanAvailable, name, parents, scan, scanOrDefault, stepName, steps, tags, tagsDeduplicated

从接口继承的方法 reactor.core.Fuseable
fusionModeName, fusionModeName

从接口继承的方法 reactor.core.Fuseable.QueueSubscription
add, addAll, contains, containsAll, element, iterator, offer, peek, remove, remove, removeAll, retainAll, toArray, toArray

从接口继承的方法 java.util.Collection
equals, hashCode, parallelStream, removeIf, spliterator, stream

从接口继承的方法 java.lang.Iterable
forEach

- 构造器详细资料
  - MonoSubscriber
```
public MonoSubscriber(CoreSubscriber<? super O> actual)
```
- 方法详细资料
  - cancel
```
public void cancel()
```
    指定者:
    
    cancel 在接口中 org.reactivestreams.Subscription
  - scanUnsafe
```
@Nullable
public java.lang.Object scanUnsafe(Scannable.Attr key)
```
    从接口复制的说明: Scannable
    
    This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Scannable.Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.
    For public consumption of attributes, prefer using Scannable.scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.
    
    参数:
    
    key - a Scannable.Attr to resolve for the component.
    
    返回:
    
    the value associated to the key for that specific component, or null if none.
  - clear
```
public final void clear()
```
    指定者:
    
    clear 在接口中 java.util.Collection<O>
  - complete
```
public final void complete(@Nullable
                           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
    
    参数:
    
    v - the value to emit
  - actual
```
public final CoreSubscriber<? super O> actual()
```
  - isCancelled
```
public final boolean isCancelled()
```
    Returns true if this Subscription has been cancelled.
    
    返回:
    
    true if this Subscription has been cancelled
  - isEmpty
```
public final boolean isEmpty()
```
    指定者:
    
    isEmpty 在接口中 java.util.Collection<O>
  - onComplete
```
public void onComplete()
```
  - onError
```
public void onError(java.lang.Throwable t)
```
  - onNext
```
public void onNext(I t)
```
  - onSubscribe
```
public void onSubscribe(org.reactivestreams.Subscription s)
```
    从接口复制的说明: CoreSubscriber
    
    Implementors should initialize any state used by Subscriber.onNext(Object) before calling Subscription.request(long). Should further onNext related state modification occur, thread-safety will be required.
    Note that an invalid request <= 0 will not produce an onError and will simply be ignored or reported through a debug-enabled Logger.
  - poll
```
@Nullable
public final O poll()
```
    指定者:
    
    poll 在接口中 java.util.Queue<O>
  - request
```
public void request(long n)
```
    指定者:
    
    request 在接口中 org.reactivestreams.Subscription
  - requestFusion
```
public int requestFusion(int mode)
```
    从接口复制的说明: 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 downstream and the fusion doesn't happen.
    
    指定者:
    
    requestFusion 在接口中 Fuseable.QueueSubscription<O>
    
    参数:
    
    mode - the mode requested by the intermediate operator
    
    返回:
    
    the actual fusion mode activated
  - setValue
```
public void setValue(@Nullable
                     O value)
```
    Set the value internally, without impacting request tracking state. This however discards the provided value when detecting a cancellation.
    
    参数:
    
    value - the new value.
    
    另请参阅:
    
    complete(Object)
  - size
```
public int size()
```
    指定者:
    
    size 在接口中 java.util.Collection<O>
  - currentContext
```
public Context currentContext()
```
    从接口复制的说明: CoreSubscriber
    
    Request a Context from dependent components which can include downstream operators during subscribing or a terminal Subscriber.
    
    返回:
    
    a resolved context or Context.empty()

类 Operators.MonoSubscriber<I,O>

嵌套类概要

从接口继承的嵌套类/接口 reactor.core.Scannable

从接口继承的嵌套类/接口 reactor.core.Fuseable

字段概要

从接口继承的字段 reactor.core.Scannable

从接口继承的字段 reactor.core.Fuseable

从接口继承的字段 reactor.core.Fuseable.QueueSubscription

构造器概要

方法概要

从类继承的方法 java.lang.Object

从接口继承的方法 reactor.core.Scannable

从接口继承的方法 reactor.core.Fuseable

从接口继承的方法 reactor.core.Fuseable.QueueSubscription

从接口继承的方法 java.util.Collection

从接口继承的方法 java.lang.Iterable

构造器详细资料

MonoSubscriber

方法详细资料

cancel

scanUnsafe

clear

complete

actual

isCancelled

isEmpty

onComplete

onError

onNext

onSubscribe

poll

request

requestFusion

setValue

size

currentContext