# Classes and Interfaces in #RxJava

Exceptions

Utility class with methods to wrap checked exceptions and manage fatal and regular exception delivery.

Class

Experimental

Class

rx.annotations

Func0

Interface

Func1

Interface

Func2

Interface

Func3

Interface

Func4

Interface

Func5

Represents a function with five arguments.

Interface

Func6

Represents a function with six arguments.

Interface

Func7

Represents a function with seven arguments.

Interface

Func8

Represents a function with eight arguments.

Interface

Func9

Represents a function with nine arguments.

Interface

FuncN

Interface

Function

Interface

Functions

Class

GroupedObservable

An Observable that has been grouped by key, the value of which can be obtained with getKey().

Class

rx.observables

ImmediateScheduler

Executes work immediately on the current thread.

Class

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

MultipleAssignmentSubscription

Class

NewThreadScheduler

Schedules work on a new thread.

Class

Notification

An object representing a notification sent to an Observable.

Class

Observable

The Observable class that implements the Reactive Pattern.

Class

Observer

Provides a mechanism for receiving push-based notifications.

Interface

Observers

Helper methods and utilities for creating and working with Observer objects.

Class

OnCompletedFailedException

Represents an exception used to re-throw errors thrown from Observer.

Class

OnErrorFailedException

Represents an exception used to re-throw errors thrown from Observer.

Class

OnErrorNotImplementedException

Represents an exception used to re-throw Observer.

Class

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

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

PublishSubject

Subject that, once an Observer has subscribed, emits all subsequently observed items to the PublishSubject

Class

RefCountSubscription

Class

ReplaySubject

Subject that buffers all items it observes and replays them to any Observer that subscribes.

Class

RxJavaErrorHandler

Abstract class for defining error handling logic in addition to the normal Observer.

Class

RxJavaObservableExecutionHook

Abstract ExecutionHook with invocations at different lifecycle points of Observable execution with a default no-op implementation.

Class

RxJavaPlugins

Registry for plugin implementations that allows global override and handles the retrieval of correct implementation based on order of precedence:

Class

RxJavaSchedulersHook

This plugin class provides 2 ways to customize Scheduler functionality 1.

Class

SafeSubscriber

SafeSubscriber is a wrapper around Subscriber that ensures that the Subscriber complies with the Observable contract.

Class

Scheduler

A Scheduler is an object that schedules units of work.

Class

Schedulers

Static factory methods for creating Schedulers.

Class

SerializedObserver

Enforces single-threaded, serialized, ordered execution of onNext(T), onCompleted(), and onError(java.

Class

SerializedSubject

Wraps a Subject so that it is safe to call its various on methods from different threads.

Class

SerializedSubscriber

Enforces single-threaded, serialized, ordered execution of onNext(T), onCompleted(), and onError(java.

Class

SerialSubscription

Represents a subscription whose underlying subscription can be swapped for another subscription which causes the previous underlying subscription to be unsubscribed.

Class

Single

The Single class implements the Reactive Pattern for a single value response.

Class

SingleSubscriber

Provides a mechanism for receiving push-based notifications.

Class

Subject

Represents an object that is both an Observable and an Observer.

Class

Subscriber

Provides a mechanism for receiving push-based notifications from Observables, and permits manual unsubscribing from these Observables.

Class

Subscribers

Helper methods and utilities for creating and working with Subscriber objects.

Class

Subscription

Subscription returns from Observable.

Interface

Subscriptions

Class

SyncOnSubscribe

A utility class to create OnSubscribe functions that respond correctly to back pressure requests from subscribers.

Class

rx.observables

TestObserver

Observer usable for unit testing to perform assertions, inspect received events or wrap a mocked Observer.

Class

TestScheduler

The TestScheduler is useful for debugging.

Class

TestSubject

A variety of Subject that is useful for testing purposes.

Class

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

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

Timestamped

Composite class that takes a value and a timestamp and wraps them.

Class