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.observers | |
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.subscriptions | |
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.
|
Class and Description |
---|
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.OnSubscribe
Callback used for building deferred computations that takes a CompletableSubscriber.
|
Completable.Operator
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.Transformer
Convenience interface and callback used by the compose operator to turn a Completable into another
Completable fluently.
|
CompletableEmitter
Abstraction over a
CompletableSubscriber that gets either an onCompleted or onError
signal and allows registering an cancellation/unsubscription callback. |
CompletableSubscriber
Represents the subscription API callbacks when subscribing to a Completable instance.
|
Emitter
Abstraction over a RxJava Subscriber that allows associating
a resource with it and exposes the current number of downstream
requested amount.
|
Emitter.BackpressureMode
Options to handle backpressure in the emitter.
|
Notification
An object representing a notification sent to an
Observable . |
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
A
Scheduler 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
Convenience type that allows a function to fluently transform a
Single into another Single via
Single.compose(rx.Single.Transformer<? super T, ? extends R>) . |
SingleEmitter
Abstraction over a
SingleSubscriber that gets either an onSuccess or onError
signal and allows registering an cancellation/unsubscription callback. |
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 from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Class and Description |
---|
Observer
Provides a mechanism for receiving push-based notifications.
|
SingleSubscriber
Provides a mechanism for receiving push-based notifications.
|
Class and 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.
|
Subscription
Subscription returns from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Class and Description |
---|
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.OnSubscribe
Callback used for building deferred computations that takes a CompletableSubscriber.
|
CompletableEmitter
Abstraction over a
CompletableSubscriber that gets either an onCompleted or onError
signal and allows registering an cancellation/unsubscription callback. |
CompletableSubscriber
Represents the subscription API callbacks when subscribing to a Completable instance.
|
Emitter
Abstraction over a RxJava Subscriber that allows associating
a resource with it and exposes the current number of downstream
requested amount.
|
Emitter.BackpressureMode
Options to handle backpressure in the emitter.
|
Notification
An object representing a notification sent to an
Observable . |
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
A
Scheduler 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.
|
SingleEmitter
Abstraction over a
SingleSubscriber that gets either an onSuccess or onError
signal and allows registering an cancellation/unsubscription callback. |
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 from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Class and 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.
|
Class and 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.
|
Scheduler
A
Scheduler 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 from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Class and Description |
---|
Subscription
Subscription returns from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Class and Description |
---|
Notification
An object representing a notification sent to an
Observable . |
Observable
The Observable class that implements the Reactive Pattern.
|
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
A
Scheduler is an object that schedules units of work. |
Single
The Single class implements the Reactive Pattern for a single value response.
|
Subscriber
Provides a mechanism for receiving push-based notifications from Observables, and permits manual
unsubscribing from these Observables.
|
Subscription
Subscription returns from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Class and 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.
|
Subscriber
Provides a mechanism for receiving push-based notifications from Observables, and permits manual
unsubscribing from these Observables.
|
Subscription
Subscription returns from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Class and Description |
---|
CompletableSubscriber
Represents the subscription API callbacks when subscribing to a Completable instance.
|
Notification
An object representing a notification sent to 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).
|
Subscriber
Provides a mechanism for receiving push-based notifications from Observables, and permits manual
unsubscribing from these Observables.
|
Subscription
Subscription returns from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Class and Description |
---|
Completable
Represents a deferred computation without any value but only indication for completion or exception.
|
Completable.OnSubscribe
Callback used for building deferred computations that takes a CompletableSubscriber.
|
Completable.Operator
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
A
Scheduler 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 from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Class and Description |
---|
Scheduler
A
Scheduler is an object that schedules units of work. |
Scheduler.Worker
Sequential Scheduler for executing actions on a single thread or event loop.
|
Class and Description |
---|
Single
The Single class implements the Reactive Pattern for a single value response.
|
Class and 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.
|
Scheduler
A
Scheduler is an object that schedules units of work. |
Class and Description |
---|
Subscription
Subscription returns from
Observable.subscribe(Subscriber) to allow unsubscribing. |
Copyright © 2018. All rights reserved.