Uses of Package
rx
-
Packages that use rx Package Description rx Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.rx.exceptions Exception handling utilities, safe subscriber exception classes, lifecycle exception classes.rx.internal.operators Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.rx.internal.producers rx.internal.schedulers rx.internal.util rx.observables Classes extending the Observable base reactive class, synchronous and asynchronous event generators.rx.observers Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.rx.plugins Callback types and a central plugin handler class to hook into the lifecycle of the base reactive types and schedulers.rx.schedulers Scheduler implementations, value+time record classes and the standard factory class to return standard RxJava schedulers or wrap any Executor-based (thread pool) instances.rx.singles Classes extending the Single base reactive class.rx.subjects Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).rx.subscriptions Default implementations for Subscription-based resource management (Subscription container types) and utility classes to construct Subscriptions from callbacks and other types. -
Classes in rx used by rx Class Description AsyncEmitter Abstraction over a RxJava Subscriber that allows associating a resource with it and exposes the current number of downstream requested amount.AsyncEmitter.BackpressureMode Options to handle backpressure in the emitter.AsyncEmitter.Cancellable A functional interface that has a single close method that can throw.BackpressureOverflow.DropLatest Drop most recent items, but notonError
nor unsubscribe from source (as {code OperatorOnBackpressureDrop}).BackpressureOverflow.DropOldest Drop oldest items from the buffer making room for newer ones.BackpressureOverflow.Error onError
a MissingBackpressureException and unsubscribe from source.BackpressureOverflow.Strategy Represents a callback called when a value is about to be dropped due to lack of downstream requests.Completable Represents a deferred computation without any value but only indication for completion or exception.Completable.CompletableOnSubscribe Callback used for building deferred computations that takes a CompletableSubscriber.Completable.CompletableOperator Convenience interface and callback used by the lift operator that given a child CompletableSubscriber, return a parent CompletableSubscriber that does any kind of lifecycle-related transformations.Completable.CompletableSubscriber Represents the subscription API callbacks when subscribing to a Completable instance.Completable.CompletableTransformer Convenience interface and callback used by the compose operator to turn a Completable into another Completable fluently.Notification An object representing a notification sent to anObservable
.Notification.Kind Specifies the kind of the notification: an element, an error or a completion notification.Observable The Observable class that implements the Reactive Pattern.Observable.OnSubscribe Invoked when Observable.subscribe is called.Observable.Operator Operator function for lifting into an Observable.Observable.Transformer Function that receives the current Observable and should return another Observable, possibly with given element type, in exchange that will be subscribed to by the downstream operators and subscribers.Observer Provides a mechanism for receiving push-based notifications.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).Scheduler AScheduler
is an object that schedules units of work.Scheduler.Worker Sequential Scheduler for executing actions on a single thread or event loop.Single The Single class implements the Reactive Pattern for a single value response.Single.OnSubscribe Invoked when Single.execute is called.Single.Transformer Transformer function used bySingle.compose(rx.Single.Transformer<? super T, ? extends R>)
.SingleSubscriber Provides a mechanism for receiving push-based notifications.Subscriber Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing. -
Classes in rx used by rx.exceptions Class Description Observer Provides a mechanism for receiving push-based notifications.SingleSubscriber Provides a mechanism for receiving push-based notifications. -
Classes in rx used by rx.internal.operators Class Description AsyncEmitter Abstraction over a RxJava Subscriber that allows associating a resource with it and exposes the current number of downstream requested amount.AsyncEmitter.BackpressureMode Options to handle backpressure in the emitter.AsyncEmitter.Cancellable A functional interface that has a single close method that can throw.BackpressureOverflow.Strategy Represents a callback called when a value is about to be dropped due to lack of downstream requests.Completable Represents a deferred computation without any value but only indication for completion or exception.Completable.CompletableOnSubscribe Callback used for building deferred computations that takes a CompletableSubscriber.Completable.CompletableSubscriber Represents the subscription API callbacks when subscribing to a Completable instance.Notification An object representing a notification sent to anObservable
.Notification.Kind Specifies the kind of the notification: an element, an error or a completion notification.Observable The Observable class that implements the Reactive Pattern.Observable.OnSubscribe Invoked when Observable.subscribe is called.Observable.Operator Operator function for lifting into an Observable.Observer Provides a mechanism for receiving push-based notifications.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).Scheduler AScheduler
is an object that schedules units of work.Scheduler.Worker Sequential Scheduler for executing actions on a single thread or event loop.Single The Single class implements the Reactive Pattern for a single value response.Single.OnSubscribe Invoked when Single.execute is called.SingleSubscriber Provides a mechanism for receiving push-based notifications.Subscriber Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing. -
Classes in rx used by rx.internal.producers Class Description Observer Provides a mechanism for receiving push-based notifications.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).Subscriber Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables. -
Classes in rx used by rx.internal.schedulers Class Description Completable Represents a deferred computation without any value but only indication for completion or exception.Observable The Observable class that implements the Reactive Pattern.Observer Provides a mechanism for receiving push-based notifications.Scheduler AScheduler
is an object that schedules units of work.Scheduler.Worker Sequential Scheduler for executing actions on a single thread or event loop.Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing. -
Classes in rx used by rx.internal.util Class Description Notification An object representing a notification sent to anObservable
.Observable The Observable class that implements the Reactive Pattern.Observable.OnSubscribe Invoked when Observable.subscribe is called.Observable.Operator Operator function for lifting into an Observable.Observer Provides a mechanism for receiving push-based notifications.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).Scheduler AScheduler
is an object that schedules units of work.Single The Single class implements the Reactive Pattern for a single value response.Single.OnSubscribe Invoked when Single.execute is called.SingleSubscriber Provides a mechanism for receiving push-based notifications.Subscriber Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing. -
Classes in rx used by rx.observables Class Description Observable The Observable class that implements the Reactive Pattern.Observable.OnSubscribe Invoked when Observable.subscribe is called.Observer Provides a mechanism for receiving push-based notifications.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).Subscriber Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing. -
Classes in rx used by rx.observers Class Description Completable.CompletableSubscriber Represents the subscription API callbacks when subscribing to a Completable instance.Notification An object representing a notification sent to anObservable
.Observer Provides a mechanism for receiving push-based notifications.Subscriber Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing. -
Classes in rx used by rx.plugins Class Description Completable Represents a deferred computation without any value but only indication for completion or exception.Completable.CompletableOnSubscribe Callback used for building deferred computations that takes a CompletableSubscriber.Completable.CompletableOperator Convenience interface and callback used by the lift operator that given a child CompletableSubscriber, return a parent CompletableSubscriber that does any kind of lifecycle-related transformations.Observable The Observable class that implements the Reactive Pattern.Observable.OnSubscribe Invoked when Observable.subscribe is called.Observable.Operator Operator function for lifting into an Observable.Scheduler AScheduler
is an object that schedules units of work.Single The Single class implements the Reactive Pattern for a single value response.Single.OnSubscribe Invoked when Single.execute is called.Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing. -
Classes in rx used by rx.schedulers Class Description Scheduler AScheduler
is an object that schedules units of work.Scheduler.Worker Sequential Scheduler for executing actions on a single thread or event loop.Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing. -
Classes in rx used by rx.singles Class Description Single The Single class implements the Reactive Pattern for a single value response. -
Classes in rx used by rx.subjects Class Description Observable The Observable class that implements the Reactive Pattern.Observable.OnSubscribe Invoked when Observable.subscribe is called.Observer Provides a mechanism for receiving push-based notifications.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).Scheduler AScheduler
is an object that schedules units of work.Scheduler.Worker Sequential Scheduler for executing actions on a single thread or event loop.Subscriber Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing. -
Classes in rx used by rx.subscriptions Class Description Subscription Subscription returns fromObservable.subscribe(Subscriber)
to allow unsubscribing.