Package com.tds.common.reactor.internal.operators
See: Description
-
Class Summary Class Description OnSubscribeFromIterable OnSubscribeFilter Filters an Observable by discarding any items it emits that do not meet some test. OnSubscribeTimeoutTimedWithFallback OnSubscribeFromArray OnSubscribeMap Applies a function of your choosing to every item emitted by an {@code Observable}, and emits the results of this transformation as a new{@code Observable}.OperatorOnErrorResumeNextViaFunction Instruct an Observable to pass control to another Observable (the return value of a function) rather than invoking {@code onError}if it encounters an error.OperatorSubscribeOn Subscribes Observers on the specified {@code Scheduler}.OperatorMerge Flattens a list of Observables into one {@code Observable}, without any transformation.OnSubscribeDoOnEach OperatorObserveOn Delivers events on the specified {@code Scheduler}asynchronously via an unbounded buffer.OnSubscribeThrow OperatorDebounceWithSelector OnSubscribeLift Transforms the downstream Subscriber into a Subscriber via an operator callback and calls the parent OnSubscribe.call() method with it. OperatorDebounceWithTime OperatorToObservableList -
Enum Summary Enum Description EmptyObservableHolder Holds a singleton instance of an empty Observable which is stateless and completes the child subscriber immediately.