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>, org.reactivestreams.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>, org.reactivestreams.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(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

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 java.util.Queue<T>

add

default boolean add(T t)

Specified by:

add in interface java.util.Collection<T>

Specified by:

add in interface java.util.Queue<T>

offer

default boolean offer(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(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(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>