| Package | Description |
|---|---|
| reactor.core.reactivestreams | |
| reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
| reactor.rx.action.combination |
| Class and Description |
|---|
| PublisherFactory.PrematureCompleteException |
| SerializedSubscriber
Enforces single-threaded, serialized, ordered execution of
SerializedSubscriber.onNext(T), SerializedSubscriber.onComplete(),
SerializedSubscriber.onError(java.lang.Throwable), SerializedSubscriber.request(long) and SerializedSubscriber.cancel(). |
| SubscriberBarrier
A
Subscriber with an asymetric typed wrapped subscriber. |
| SubscriberWithContext
A
Subscriber with a typed stateful context. |
| SubscriptionWithContext
A
Subscription with a typed stateful context. |
| Class and Description |
|---|
| SubscriberWithContext
A
Subscriber with a typed stateful context. |
| Class and Description |
|---|
| SerializedSubscriber
Enforces single-threaded, serialized, ordered execution of
SerializedSubscriber.onNext(T), SerializedSubscriber.onComplete(),
SerializedSubscriber.onError(java.lang.Throwable), SerializedSubscriber.request(long) and SerializedSubscriber.cancel(). |
Copyright © 2016. All rights reserved.