reactor.core

Interface Fuseable.SynchronousSubscription<T>

Type Parameters:

T - the content value type

All Superinterfaces:

Collection<T>, Fuseable.QueueSubscription<T>, Iterable<T>, Queue<T>, Subscription

Enclosing interface:

Fuseable

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

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

Method Summary

Modifier and Type	Method and Description
default int	requestFusion(int requestedMode) Request a specific fusion mode from this QueueSubscription.

Methods inherited from interface reactor.core.Fuseable.QueueSubscription

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

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

default int requestFusion(int requestedMode)

Description copied from interface: 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 dowstream and the fusion doesn't happen.

Specified by:

requestFusion in interface Fuseable.QueueSubscription<T>

Parameters:

requestedMode - the mode to request

Returns:

the fusion mode activated