Interface | Description |
---|---|
InnerQueuedSubscriberSupport<T> |
Interface to allow the InnerQueuedSubscriber to call back a parent
with signals.
|
Class | Description |
---|---|
BasicFuseableConditionalSubscriber<T,R> |
Base class for a fuseable intermediate subscriber.
|
BasicFuseableSubscriber<T,R> |
Base class for a fuseable intermediate subscriber.
|
BlockingBaseSubscriber<T> | |
BlockingFirstSubscriber<T> |
Blocks until the upstream signals its first value or completes.
|
BlockingLastSubscriber<T> |
Blocks until the upstream signals its last value or completes.
|
BlockingSubscriber<T> | |
BoundedSubscriber<T> | |
DeferredScalarSubscriber<T,R> |
A subscriber, extending a DeferredScalarSubscription,
that is unbounded-in and can generate 0 or 1 resulting value.
|
ForEachWhileSubscriber<T> | |
FutureSubscriber<T> |
A Subscriber + Future that expects exactly one upstream value and provides it
via the (blocking) Future API.
|
InnerQueuedSubscriber<T> |
Subscriber that can fuse with the upstream and calls a support interface
whenever an event is available.
|
LambdaSubscriber<T> | |
QueueDrainSubscriber<T,U,V> |
Abstract base class for subscribers that hold another subscriber, a queue
and requires queue-drain behavior.
|
SinglePostCompleteSubscriber<T,R> |
Relays signals from upstream according to downstream requests and allows
signalling a final value followed by onComplete in a backpressure-aware manner.
|
StrictSubscriber<T> |
Ensures that the event flow between the upstream and downstream follow
the Reactive-Streams 1.0 specification by honoring the 3 additional rules
(which are omitted in standard operators due to performance reasons).
|
SubscriberResourceWrapper<T> |
Copyright © 2018 JBoss by Red Hat. All rights reserved.