reactor.core

Interface Fuseable.QueueSubscription<T>

Type Parameters:

T - the value type emitted

All Superinterfaces:

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

All Known Subinterfaces:

Fuseable.SynchronousSubscription<T>

All Known Implementing Classes:

Operators.MonoSubscriber, UnicastProcessor

Enclosing interface:

Fuseable

public static interface Fuseable.QueueSubscription<T>
extends java.util.Queue<T>, 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.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NOT_SUPPORTED_MESSAGE

Method Summary

Modifier and Type	Method and Description
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)

Methods inherited from interface java.util.Queue

poll

Methods inherited from interface java.util.Collection

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

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface org.reactivestreams.Subscription

cancel, request

Field Detail

NOT_SUPPORTED_MESSAGE

static final java.lang.String NOT_SUPPORTED_MESSAGE

See Also:

Constant Field Values

Method Detail

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.

Parameters:

requestedMode - the mode requested by the intermediate operator

Returns:

the actual fusion mode activated

peek

@Nullable
default T peek()

Specified by:

peek in interface java.util.Queue<T>

add

default boolean add(@Nullable
                    T t)

Specified by:

add in interface java.util.Collection<T>

Specified by:

add in interface java.util.Queue<T>

offer

default boolean offer(@Nullable
                      T t)

Specified by:

offer in interface java.util.Queue<T>

remove

default T remove()

Specified by:

remove in interface java.util.Queue<T>

element

default T element()

Specified by:

element in interface java.util.Queue<T>

contains

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

Specified by:

contains in interface java.util.Collection<T>

iterator

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

Specified by:

iterator in interface java.util.Collection<T>

Specified by:

iterator in interface java.lang.Iterable<T>

toArray

default java.lang.Object[] toArray()

Specified by:

toArray in interface java.util.Collection<T>

toArray

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

Specified by:

toArray in interface java.util.Collection<T>

remove

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

Specified by:

remove in interface java.util.Collection<T>

containsAll

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

Specified by:

containsAll in interface java.util.Collection<T>

addAll

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

Specified by:

addAll in interface java.util.Collection<T>

removeAll

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

Specified by:

removeAll in interface java.util.Collection<T>

retainAll

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

Specified by:

retainAll in interface java.util.Collection<T>