Uses of Interface
reactor.core.queue.CompletableQueue

Packages that use CompletableQueue

Package	Description
reactor.core.queue	Queue implementations that provide completable states or lock-free queue
reactor.io.queue	Queue implementations that provide a persistence strategy for making sure items in the Queue aren't lost.
reactor.rx	Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
reactor.rx.action	Actions are Reactive Streams components derived from Reactive Extensions and beyond.
reactor.rx.action.aggregation
reactor.rx.action.control
reactor.rx.broadcast	Broadcasters are akin to Reactive Extensions Subject.
reactor.rx.subscription

Uses of CompletableQueue in reactor.core.queue

Classes in reactor.core.queue that implement CompletableQueue

Modifier and Type	Class and Description
class	CompletableBlockingQueue<T> A LinkedQueue that supports a terminal state.
class	CompletableLinkedQueue<T> A LinkedQueue that supports a terminal state.

Uses of CompletableQueue in reactor.io.queue

Classes in reactor.io.queue that implement CompletableQueue

Modifier and Type	Class and Description
class	PersistentQueue<T> A PersistentQueue is a Queue implementation that delegates the actual storage of the elements in the queue to a QueuePersistor.

Uses of CompletableQueue in reactor.rx

Method parameters in reactor.rx with type arguments of type CompletableQueue

Modifier and Type	Method and Description
Stream<O>	Stream.onOverflowBuffer(Supplier<? extends CompletableQueue<O>> queueSupplier) Attach a No-Op Action that only serves the purpose of buffering incoming values if not enough demand is signaled downstream.

Uses of CompletableQueue in reactor.rx.action

Methods in reactor.rx.action with parameters of type CompletableQueue

Modifier and Type	Method and Description
protected PushSubscription<O>	Action.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber, CompletableQueue<O> queue)

Method parameters in reactor.rx.action with type arguments of type CompletableQueue

Modifier and Type	Method and Description
Stream<O>	Action.onOverflowBuffer(Supplier<? extends CompletableQueue<O>> queueSupplier)

Uses of CompletableQueue in reactor.rx.action.aggregation

Methods in reactor.rx.action.aggregation with parameters of type CompletableQueue

Modifier and Type	Method and Description
protected PushSubscription<T>	CacheAction.createSubscription(org.reactivestreams.Subscriber<? super T> subscriber, CompletableQueue<T> queue)

Uses of CompletableQueue in reactor.rx.action.control

Constructor parameters in reactor.rx.action.control with type arguments of type CompletableQueue

Constructor and Description
FlowControlAction(Supplier<? extends CompletableQueue<O>> queueSupplier)

Uses of CompletableQueue in reactor.rx.broadcast

Methods in reactor.rx.broadcast with parameters of type CompletableQueue

Modifier and Type	Method and Description
protected PushSubscription<O>	BehaviorBroadcaster.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber, CompletableQueue<O> queue)
protected PushSubscription<O>	Broadcaster.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber, CompletableQueue<O> queue)

Uses of CompletableQueue in reactor.rx.subscription

Fields in reactor.rx.subscription declared as CompletableQueue

Modifier and Type	Field and Description
protected CompletableQueue<O>	ReactiveSubscription.buffer

Methods in reactor.rx.subscription that return CompletableQueue

Modifier and Type	Method and Description
CompletableQueue<O>	ReactiveSubscription.getBuffer()

Constructors in reactor.rx.subscription with parameters of type CompletableQueue

Constructor and Description
ReactiveSubscription(Stream<O> publisher, org.reactivestreams.Subscriber<? super O> subscriber, CompletableQueue<O> buffer)