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 |
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.
|
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 . |
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.
|
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<O> |
Action.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
CompletableQueue<O> queue) |
Modifier and Type | Method and Description |
---|---|
Stream<O> |
Action.onOverflowBuffer(Supplier<? extends CompletableQueue<O>> queueSupplier) |
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<T> |
CacheAction.createSubscription(org.reactivestreams.Subscriber<? super T> subscriber,
CompletableQueue<T> queue) |
Constructor and Description |
---|
FlowControlAction(Supplier<? extends CompletableQueue<O>> queueSupplier) |
Modifier and Type | Method and Description |
---|---|
protected PushSubscription<O> |
Broadcaster.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
CompletableQueue<O> queue) |
protected PushSubscription<O> |
BehaviorBroadcaster.createSubscription(org.reactivestreams.Subscriber<? super O> subscriber,
CompletableQueue<O> queue) |
Modifier and Type | Field and Description |
---|---|
protected CompletableQueue<O> |
ReactiveSubscription.buffer |
Modifier and Type | Method and Description |
---|---|
CompletableQueue<O> |
ReactiveSubscription.getBuffer() |
Constructor and Description |
---|
ReactiveSubscription(Stream<O> publisher,
org.reactivestreams.Subscriber<? super O> subscriber,
CompletableQueue<O> buffer) |
Copyright © 2017. All rights reserved.