reactor.core

Interface Fuseable.QueueSubscription<T>

Type Parameters:

T - the value type emitted

All Superinterfaces:

Collection<T>, Iterable<T>, 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 Queue<T>, Subscription

Contract queue-fusion based optimizations for supporting subscriptions.

• Synchronous sources which have fixed size and can emit its 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.

Method Summary

Modifier and Type	Method and Description
default boolean	add(T t)
default boolean	addAll(Collection<? extends T> c)
default boolean	contains(Object o)
default boolean	containsAll(Collection<?> c)
default T	element()
default Iterator<T>	iterator()
default boolean	offer(T t)
default T	peek()
default T	remove()
default boolean	remove(Object o)
default boolean	removeAll(Collection<?> c)
int	requestFusion(int requestedMode) Request a specific fusion mode from this QueueSubscription.
default boolean	retainAll(Collection<?> c)
default 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

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 dowstream and the fusion doesn't happen.

Parameters:

requestedMode - the mode to request

Returns:

the fusion mode activated

peek

default T peek()

Specified by:

peek in interface Queue<T>

add

default boolean add(T t)

Specified by:

add in interface Collection<T>

Specified by:

add in interface Queue<T>

offer

default boolean offer(T t)

Specified by:

offer in interface Queue<T>

remove

default T remove()

Specified by:

remove in interface Queue<T>

element

default T element()

Specified by:

element in interface Queue<T>

contains

default boolean contains(Object o)

Specified by:

contains in interface Collection<T>

iterator

default Iterator<T> iterator()

Specified by:

iterator in interface Collection<T>

Specified by:

iterator in interface Iterable<T>

toArray

default Object[] toArray()

Specified by:

toArray in interface Collection<T>

toArray

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

Specified by:

toArray in interface Collection<T>

remove

default boolean remove(Object o)

Specified by:

remove in interface Collection<T>

containsAll

default boolean containsAll(Collection<?> c)

Specified by:

containsAll in interface Collection<T>

addAll

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

Specified by:

addAll in interface Collection<T>

removeAll

default boolean removeAll(Collection<?> c)

Specified by:

removeAll in interface Collection<T>

retainAll

default boolean retainAll(Collection<?> c)

Specified by:

retainAll in interface Collection<T>