Uses of Package
rx

Packages that use rx
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
Exception handling utilities, safe subscriber exception classes, lifecycle exception classes.
Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
 
 
 
Classes extending the Observable base reactive class, synchronous and asynchronous event generators.
Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.
Callback types and a central plugin handler class to hook into the lifecycle of the base reactive types and 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.
Classes extending the Single base reactive class.
Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables).
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
    Abstraction over a RxJava Subscriber that allows associating a resource with it and exposes the current number of downstream requested amount.
    Options to handle backpressure in the emitter.
    A functional interface that has a single close method that can throw.
    Drop most recent items, but not onError nor unsubscribe from source (as {code OperatorOnBackpressureDrop}).
    Drop oldest items from the buffer making room for newer ones.
    onError a MissingBackpressureException and unsubscribe from source.
    Represents a callback called when a value is about to be dropped due to lack of downstream requests.
    Represents a deferred computation without any value but only indication for completion or exception.
    Callback used for building deferred computations that takes a CompletableSubscriber.
    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.
    Represents the subscription API callbacks when subscribing to a Completable instance.
    Convenience interface and callback used by the compose operator to turn a Completable into another Completable fluently.
    An object representing a notification sent to an Observable.
    Specifies the kind of the notification: an element, an error or a completion notification.
    The Observable class that implements the Reactive Pattern.
    Invoked when Observable.subscribe is called.
    Operator function for lifting into an Observable.
    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.
    Provides a mechanism for receiving push-based notifications.
    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).
    A Scheduler is an object that schedules units of work.
    Sequential Scheduler for executing actions on a single thread or event loop.
    The Single class implements the Reactive Pattern for a single value response.
    Invoked when Single.execute is called.
    Provides a mechanism for receiving push-based notifications.
    Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
  • Classes in rx used by rx.exceptions
    Class
    Description
    Provides a mechanism for receiving push-based notifications.
    Provides a mechanism for receiving push-based notifications.
  • Classes in rx used by rx.internal.operators
    Class
    Description
    Abstraction over a RxJava Subscriber that allows associating a resource with it and exposes the current number of downstream requested amount.
    Options to handle backpressure in the emitter.
    A functional interface that has a single close method that can throw.
    Represents a callback called when a value is about to be dropped due to lack of downstream requests.
    Represents a deferred computation without any value but only indication for completion or exception.
    Callback used for building deferred computations that takes a CompletableSubscriber.
    Represents the subscription API callbacks when subscribing to a Completable instance.
    An object representing a notification sent to an Observable.
    Specifies the kind of the notification: an element, an error or a completion notification.
    The Observable class that implements the Reactive Pattern.
    Invoked when Observable.subscribe is called.
    Operator function for lifting into an Observable.
    Provides a mechanism for receiving push-based notifications.
    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).
    A Scheduler is an object that schedules units of work.
    Sequential Scheduler for executing actions on a single thread or event loop.
    The Single class implements the Reactive Pattern for a single value response.
    Invoked when Single.execute is called.
    Provides a mechanism for receiving push-based notifications.
    Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
  • Classes in rx used by rx.internal.producers
    Class
    Description
    Provides a mechanism for receiving push-based notifications.
    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).
    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
    Represents a deferred computation without any value but only indication for completion or exception.
    The Observable class that implements the Reactive Pattern.
    Provides a mechanism for receiving push-based notifications.
    A Scheduler is an object that schedules units of work.
    Sequential Scheduler for executing actions on a single thread or event loop.
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
  • Classes in rx used by rx.internal.util
    Class
    Description
    An object representing a notification sent to an Observable.
    The Observable class that implements the Reactive Pattern.
    Invoked when Observable.subscribe is called.
    Operator function for lifting into an Observable.
    Provides a mechanism for receiving push-based notifications.
    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).
    A Scheduler is an object that schedules units of work.
    The Single class implements the Reactive Pattern for a single value response.
    Invoked when Single.execute is called.
    Provides a mechanism for receiving push-based notifications.
    Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
  • Classes in rx used by rx.observables
    Class
    Description
    The Observable class that implements the Reactive Pattern.
    Invoked when Observable.subscribe is called.
    Provides a mechanism for receiving push-based notifications.
    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).
    Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
  • Classes in rx used by rx.observers
    Class
    Description
    Represents the subscription API callbacks when subscribing to a Completable instance.
    An object representing a notification sent to an Observable.
    Provides a mechanism for receiving push-based notifications.
    Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
  • Classes in rx used by rx.plugins
    Class
    Description
    Represents a deferred computation without any value but only indication for completion or exception.
    Callback used for building deferred computations that takes a CompletableSubscriber.
    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.
    The Observable class that implements the Reactive Pattern.
    Invoked when Observable.subscribe is called.
    Operator function for lifting into an Observable.
    A Scheduler is an object that schedules units of work.
    The Single class implements the Reactive Pattern for a single value response.
    Invoked when Single.execute is called.
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
  • Classes in rx used by rx.schedulers
    Class
    Description
    A Scheduler is an object that schedules units of work.
    Sequential Scheduler for executing actions on a single thread or event loop.
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
  • Classes in rx used by rx.singles
    Class
    Description
    The Single class implements the Reactive Pattern for a single value response.
  • Classes in rx used by rx.subjects
    Class
    Description
    The Observable class that implements the Reactive Pattern.
    Invoked when Observable.subscribe is called.
    Provides a mechanism for receiving push-based notifications.
    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).
    A Scheduler is an object that schedules units of work.
    Sequential Scheduler for executing actions on a single thread or event loop.
    Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.
  • Classes in rx used by rx.subscriptions
    Class
    Description
    Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.