reactor.core.publisher

类 Operators.DeferredSubscription

java.lang.Object

reactor.core.publisher.Operators.DeferredSubscription

所有已实现的接口:

org.reactivestreams.Subscription, Scannable

封闭类:

Operators

public static class Operators.DeferredSubscription
extends java.lang.Object
implements org.reactivestreams.Subscription, Scannable

Base class for Subscribers that will receive their Subscriptions at any time, yet they might also need to be cancelled or requested at any time.

嵌套类概要

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

Scannable.Attr<T>

字段概要

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

OPERATOR_NAME_UNRELATED_WORDS_PATTERN

构造器概要

构造器

构造器和说明
DeferredSubscription()

方法概要

限定符和类型	方法和说明
void	cancel()
void	request(long n)
java.lang.Object	scanUnsafe(Scannable.Attr key) This method is used internally by components to define their key-value mappings in a single place.
boolean	set(org.reactivestreams.Subscription s) Atomically sets the single subscription and requests the missed amount from it.

从类继承的方法 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

构造器详细资料

DeferredSubscription

public DeferredSubscription()

方法详细资料

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.

指定者:

scanUnsafe 在接口中 Scannable

参数:

key - a Scannable.Attr to resolve for the component.

返回:

the value associated to the key for that specific component, or null if none.

request

public void request(long n)

指定者:

request 在接口中 org.reactivestreams.Subscription

set

public final boolean set(org.reactivestreams.Subscription s)

Atomically sets the single subscription and requests the missed amount from it.

参数:

s - the subscription to set

返回:

false if this arbiter is cancelled or there was a subscription already set