Uses of Class
reactor.core.queue.CompletableBlockingQueue

Packages that use CompletableBlockingQueue

Package	Description
reactor.rx	Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.

Uses of CompletableBlockingQueue in reactor.rx

Methods in reactor.rx that return CompletableBlockingQueue

Modifier and Type	Method and Description
CompletableBlockingQueue<O>	Stream.toBlockingQueue() Blocking call to pass values from this stream to the queue that can be polled from a consumer.
CompletableBlockingQueue<O>	Stream.toBlockingQueue(int maximum) Blocking call to eagerly fetch values from this stream