Name Description Type Package Framework
Action Interface rx.functions RxJava Action0 Interface rx.functions RxJava Action1 Interface rx.functions RxJava Action2 Interface rx.functions RxJava Action3 Interface rx.functions RxJava Action4 Interface rx.functions RxJava Action5 Interface rx.functions RxJava Action6 A six-argument action. Interface rx.functions RxJava Action7 A seven-argument action. Interface rx.functions RxJava Action8 An eight-argument action. Interface rx.functions RxJava Action9 A nine-argument action. Interface rx.functions RxJava ActionN Interface rx.functions RxJava Actions Utility class for the Action interfaces. Class rx.functions RxJava AsyncOnSubscribe A utility class to create OnSubscribe functions that respond correctly to back pressure requests from subscribers. Class rx.observables RxJava AsyncSubject Subject that publishes only the last item observed to each Observer that has subscribed, when the source Observable completes. Class rx.subjects RxJava BehaviorSubject Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed // observer will receive all events. Class rx.subjects RxJava Beta Signifies that a public API (public class, method or field) is subject to incompatible changes, or even removal, in a future release. Class rx.annotations RxJava BlockingObservable BlockingObservable is a variety of Observable that provides blocking operators. Class rx.observables RxJava BlockingSingle BlockingSingle is a blocking "version" of Single that provides blocking You construct a BlockingSingle from a Single with from(Single) Class rx.singles RxJava BooleanSubscription Class rx.subscriptions RxJava Completable Represents a deferred computation without any value but only indication for completion or exception. Class rx RxJava CompositeException Represents an exception that is a composite of one or more other exceptions. Class rx.exceptions RxJava CompositeSubscription Subscription that represents a group of Subscriptions that are unsubscribed together. Class rx.subscriptions RxJava ConnectableObservable A ConnectableObservable resembles an ordinary Observable, except that it does not begin emitting items when it is subscribed to, but only when its connect() method is called. Class rx.observables RxJava Exceptions Utility class with methods to wrap checked exceptions and manage fatal and regular exception delivery. Class rx.exceptions RxJava Experimental Class rx.annotations RxJava Func0 Interface rx.functions RxJava Func1 Interface rx.functions RxJava Func2 Interface rx.functions RxJava Func3 Interface rx.functions RxJava Func4 Interface rx.functions RxJava Func5 Represents a function with five arguments. Interface rx.functions RxJava Func6 Represents a function with six arguments. Interface rx.functions RxJava Func7 Represents a function with seven arguments. Interface rx.functions RxJava Func8 Represents a function with eight arguments. Interface rx.functions RxJava Func9 Represents a function with nine arguments. Interface rx.functions RxJava FuncN Interface rx.functions RxJava Function Interface rx.functions RxJava Functions Class rx.functions RxJava GroupedObservable An Observable that has been grouped by key, the value of which can be obtained with getKey(). Class rx.observables RxJava ImmediateScheduler Executes work immediately on the current thread. Class rx.schedulers RxJava MissingBackpressureException Represents an exception that indicates that a Subscriber or operator attempted to apply reactive pull backpressure to an Observable that does not implement it. Class rx.exceptions RxJava MultipleAssignmentSubscription Class rx.subscriptions RxJava NewThreadScheduler Schedules work on a new thread. Class rx.schedulers RxJava Notification An object representing a notification sent to an Observable. Class rx RxJava Observable The Observable class that implements the Reactive Pattern. Class rx RxJava Observer Provides a mechanism for receiving push-based notifications. Interface rx RxJava Observers Helper methods and utilities for creating and working with Observer objects. Class rx.observers RxJava OnCompletedFailedException Represents an exception used to re-throw errors thrown from Observer. Class rx.exceptions RxJava OnErrorFailedException Represents an exception used to re-throw errors thrown from Observer. Class rx.exceptions RxJava OnErrorNotImplementedException Represents an exception used to re-throw Observer. Class rx.exceptions RxJava OnErrorThrowable Represents a Throwable that an Observable might notify its subscribers of, but that then can be handled by an operator that is designed to recover from or react appropriately to such an error. Class rx.exceptions RxJava 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 Interface rx RxJava PublishSubject Subject that, once an Observer has subscribed, emits all subsequently observed items to the PublishSubject subject = PublishSubject. Class rx.subjects RxJava RefCountSubscription Class rx.subscriptions RxJava ReplaySubject Subject that buffers all items it observes and replays them to any Observer that subscribes. Class rx.subjects RxJava RxJavaErrorHandler Abstract class for defining error handling logic in addition to the normal Observer. Class rx.plugins RxJava RxJavaObservableExecutionHook Abstract ExecutionHook with invocations at different lifecycle points of Observable execution with a default no-op implementation. Class rx.plugins RxJava RxJavaPlugins Registry for plugin implementations that allows global override and handles the retrieval of correct implementation based on order of precedence: Class rx.plugins RxJava RxJavaSchedulersHook This plugin class provides 2 ways to customize Scheduler functionality 1. Class rx.plugins RxJava SafeSubscriber SafeSubscriber is a wrapper around Subscriber that ensures that the Subscriber complies with the Observable contract. Class rx.observers RxJava Scheduler A Scheduler is an object that schedules units of work. Class rx RxJava Schedulers Static factory methods for creating Schedulers. Class rx.schedulers RxJava SerializedObserver Enforces single-threaded, serialized, ordered execution of onNext(T), onCompleted(), and onError(java. Class rx.observers RxJava SerializedSubject Wraps a Subject so that it is safe to call its various on methods from different threads. Class rx.subjects RxJava SerializedSubscriber Enforces single-threaded, serialized, ordered execution of onNext(T), onCompleted(), and onError(java. Class rx.observers RxJava SerialSubscription Represents a subscription whose underlying subscription can be swapped for another subscription which causes the previous underlying subscription to be unsubscribed. Class rx.subscriptions RxJava Single The Single class implements the Reactive Pattern for a single value response. Class rx RxJava SingleSubscriber Provides a mechanism for receiving push-based notifications. Class rx RxJava Subject Represents an object that is both an Observable and an Observer. Class rx.subjects RxJava Subscriber Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables. Class rx RxJava Subscribers Helper methods and utilities for creating and working with Subscriber objects. Class rx.observers RxJava Subscription Subscription returns from Observable. Interface rx RxJava Subscriptions Class rx.subscriptions RxJava SyncOnSubscribe A utility class to create OnSubscribe functions that respond correctly to back pressure requests from subscribers. Class rx.observables RxJava TestObserver Observer usable for unit testing to perform assertions, inspect received events or wrap a mocked Observer. Class rx.observers RxJava TestScheduler The TestScheduler is useful for debugging. Class rx.schedulers RxJava TestSubject A variety of Subject that is useful for testing purposes. Class rx.subjects RxJava TestSubscriber A TestSubscriber is a variety of Subscriber that you can use for unit testing, to perform assertions, inspect received events, or wrap a mocked Subscriber. Class rx.observers RxJava TimeInterval A TimeInterval represents an item emitted by an Observable along with the amount of time that elapsed either since the emission of the previous item or (if there was no previous item) since the Class rx.schedulers RxJava Timestamped Composite class that takes a value and a timestamp and wraps them. Class rx.schedulers RxJava TrampolineScheduler Schedules work on the current thread but does not execute immediately. Class rx.schedulers RxJava UnsubscribeFailedException Represents an exception used to re-throw errors thrown from Subscriber. Class rx.exceptions RxJava