Class | Description |
---|---|
PublisherFactory |
A Reactive Streams
Publisher factory which callbacks on start, request and shutdown
The Publisher will directly forward all the signals passed to the subscribers and complete when onComplete is called. |
SerializedSubscriber<T> |
Enforces single-threaded, serialized, ordered execution of
SerializedSubscriber.onNext(T) , SerializedSubscriber.onComplete() ,
SerializedSubscriber.onError(java.lang.Throwable) , SerializedSubscriber.request(long) and SerializedSubscriber.cancel() . |
SubscriberBarrier<I,O> |
A
Subscriber with an asymetric typed wrapped subscriber. |
SubscriberFactory |
A Reactive Streams
Subscriber factory which callbacks on start, onNext, onError and shutdown
The Publisher will directly forward all the signals passed to the subscribers and complete when onComplete is called. |
SubscriberWithContext<T,C> |
A
Subscriber with a typed stateful context. |
SubscriptionWithContext<C> |
A
Subscription with a typed stateful context. |
Exception | Description |
---|---|
PublisherFactory.PrematureCompleteException |
Copyright © 2016. All rights reserved.