Package com.tds.common.reactor
See: Description
-
Class Summary Class Description Subscriber RxBus Observable -
Interface Summary Interface Description OnSubscribe Invoked when Observable.subscribe is called. Operator Producer Interface that establishes a request-channel between an Observable and a Subscriber and allows the Subscriber to request a certain amount of items from the Observable (otherwise known as backpressure). Action Subscription Subscription returns from subscribe to allow unsubscribing. Observer Emitter Abstraction over a RxJava Subscriber that allows associating a resource with it and exposes the current number of downstream requested amount. -
Enum Summary Enum Description BackpressureMode Options to handle backpressure in the emitter.