reactor.core

接口 Fuseable.SynchronousSubscription<T>

类型参数:

T - the content value type

所有超级接口:

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

封闭接口:

Fuseable

public static interface Fuseable.SynchronousSubscription<T>
extends Fuseable.QueueSubscription<T>

Base class for synchronous sources which have fixed size and can emit their items in a pull fashion, thus avoiding the request-accounting overhead in many cases.

字段概要

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

NOT_SUPPORTED_MESSAGE

方法概要

限定符和类型	方法和说明
default int	requestFusion(int requestedMode) Request a specific fusion mode from this QueueSubscription.

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

add, addAll, contains, containsAll, element, iterator, offer, peek, remove, remove, removeAll, retainAll, toArray, toArray

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

poll

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

clear, equals, hashCode, isEmpty, parallelStream, removeIf, size, spliterator, stream

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

forEach

从接口继承的方法 org.reactivestreams.Subscription

cancel, request

方法详细资料

requestFusion

default int requestFusion(int requestedMode)

从接口复制的说明: 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<T>

参数:

requestedMode - the mode requested by the intermediate operator

返回:

the actual fusion mode activated