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.