reactor.core

接口 Fuseable.QueueSubscription<T>

类型参数:

T - the value type emitted

所有超级接口:

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

所有已知子接口:

Fuseable.SynchronousSubscription<T>

所有已知实现类:

Operators.MonoSubscriber, UnicastProcessor

封闭接口:

Fuseable

public static interface Fuseable.QueueSubscription<T>
extends java.util.Queue<T>, org.reactivestreams.Subscription

Support contract for queue-fusion based optimizations on subscriptions.

• Synchronous sources which have fixed size and can emit their items in a pull fashion, thus avoiding the request-accounting overhead in many cases.
• Asynchronous sources which can act as a queue and subscription at the same time, saving on allocating another queue most of the time.

字段概要

字段

限定符和类型	字段和说明
static java.lang.String	NOT_SUPPORTED_MESSAGE

方法概要

限定符和类型	方法和说明
default boolean	add(T t)
default boolean	addAll(java.util.Collection<? extends T> c)
default boolean	contains(java.lang.Object o)
default boolean	containsAll(java.util.Collection<?> c)
default T	element()
default java.util.Iterator<T>	iterator()
default boolean	offer(T t)
default T	peek()
default T	remove()
default boolean	remove(java.lang.Object o)
default boolean	removeAll(java.util.Collection<?> c)
int	requestFusion(int requestedMode) Request a specific fusion mode from this QueueSubscription.
default boolean	retainAll(java.util.Collection<?> c)
default java.lang.Object[]	toArray()
default <T1> T1[]	toArray(T1[] a)

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

字段详细资料

NOT_SUPPORTED_MESSAGE

static final java.lang.String NOT_SUPPORTED_MESSAGE

另请参阅:

常量字段值

方法详细资料

requestFusion

int requestFusion(int requestedMode)

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.

参数:

requestedMode - the mode requested by the intermediate operator

返回:

the actual fusion mode activated

peek

@Nullable
default T peek()

指定者:

peek 在接口中 java.util.Queue<T>

add

default boolean add(@Nullable
                    T t)

指定者:

add 在接口中 java.util.Collection<T>

指定者:

add 在接口中 java.util.Queue<T>

offer

default boolean offer(@Nullable
                      T t)

指定者:

offer 在接口中 java.util.Queue<T>

remove

default T remove()

指定者:

remove 在接口中 java.util.Queue<T>

element

default T element()

指定者:

element 在接口中 java.util.Queue<T>

contains

default boolean contains(@Nullable
                         java.lang.Object o)

指定者:

contains 在接口中 java.util.Collection<T>

iterator

default java.util.Iterator<T> iterator()

指定者:

iterator 在接口中 java.util.Collection<T>

指定者:

iterator 在接口中 java.lang.Iterable<T>

toArray

default java.lang.Object[] toArray()

指定者:

toArray 在接口中 java.util.Collection<T>

toArray

default <T1> T1[] toArray(T1[] a)

指定者:

toArray 在接口中 java.util.Collection<T>

remove

default boolean remove(@Nullable
                       java.lang.Object o)

指定者:

remove 在接口中 java.util.Collection<T>

containsAll

default boolean containsAll(java.util.Collection<?> c)

指定者:

containsAll 在接口中 java.util.Collection<T>

addAll

default boolean addAll(java.util.Collection<? extends T> c)

指定者:

addAll 在接口中 java.util.Collection<T>

removeAll

default boolean removeAll(java.util.Collection<?> c)

指定者:

removeAll 在接口中 java.util.Collection<T>

retainAll

default boolean retainAll(java.util.Collection<?> c)

指定者:

retainAll 在接口中 java.util.Collection<T>