T- the content value type
public static interface Fuseable.SynchronousSubscription<T> extends Fuseable.QueueSubscription<T>, Queue<T>
|Modifier and Type||Method and Description|
Request a specific fusion mode from this QueueSubscription.
add, addAll, contains, containsAll, element, iterator, offer, peek, remove, remove, removeAll, retainAll, toArray, toArray
clear, equals, hashCode, isEmpty, parallelStream, removeIf, size, spliterator, stream
default int requestFusion(int requestedMode)
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.