RxJava 2 2.2.21 · io.reactivex.observers

Default wrappers and implementations for Observer-based consumer classes and interfaces, including disposable and resource-tracking variants and the io.reactivex.observers.TestObserver that allows unit testing io.reactivex.Observable-, io.reactivex.Single-, io.reactivex.Maybe- and io.reactivex.Completable-based flows.

Modifier and Type	Interface and Description
public interface	LambdaConsumerIntrospection An interface that indicates that the implementing type is composed of individual components and exposes information about their behavior.

Class Summary

Modifier and Type	Class and Description
public abstract class	BaseTestConsumer< the value type consumed T, the subclass of this BaseTestConsumer U extends BaseTestConsumer<T, U>> Base class with shared infrastructure to support TestSubscriber and TestObserver.
public abstract class	DefaultObserver< the value type T> Abstract base implementation of an `Observer` with support for cancelling a subscription via `cancel()` (synchronously) and calls `onStart()` when the subscription happens.
public abstract class	DisposableCompletableObserver An abstract `CompletableObserver` that allows asynchronous cancellation by implementing Disposable.
public abstract class	DisposableMaybeObserver< the received value type T> An abstract `MaybeObserver` that allows asynchronous cancellation by implementing Disposable.
public abstract class	DisposableObserver< the received value type T> An abstract `Observer` that allows asynchronous cancellation by implementing Disposable.
public abstract class	DisposableSingleObserver< the received value type T> An abstract `SingleObserver` that allows asynchronous cancellation by implementing Disposable.
public abstract class	ResourceCompletableObserver An abstract `CompletableObserver` that allows asynchronous cancellation of its subscription and associated resources.
public abstract class	ResourceMaybeObserver< the value type T> An abstract `MaybeObserver` that allows asynchronous cancellation of its subscription and associated resources.
public abstract class	ResourceObserver< the value type T> An abstract `Observer` that allows asynchronous cancellation of its subscription and associated resources.
public abstract class	ResourceSingleObserver< the value type T> An abstract `SingleObserver` that allows asynchronous cancellation of its subscription and the associated resources.
public class	SafeObserver< the value type T> Wraps another Subscriber and ensures all onXXX methods conform the protocol (except the requirement for serialized access).
public class	SerializedObserver< the value type T> Serializes access to the onNext, onError and onComplete methods of another Observer.
public class	TestObserver< the value type T> An Observer that records events and allows making assertions about them.

Package io.reactivex.observers

Interface Summary

Class Summary