Package | Description |
---|---|
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
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
|
Copyright © 2016. All rights reserved.