RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.observers

Modifier and Type	Interface and Description
public interface	InnerQueuedObserverSupport< the value type T> Interface to allow the InnerQueuedSubscriber to call back a parent with signals.

Class Summary

Modifier and Type	Class and Description
pack-priv abstract class	AbstractDisposableAutoRelease Wraps lambda callbacks and when the upstream terminates or the observer gets disposed, removes itself from a `io.reactivex.rxjava3.disposables.CompositeDisposable`.
public abstract class	BasicFuseableObserver< the upstream value type T, the downstream value type R> Base class for a fuseable intermediate observer.
public abstract class	BasicIntQueueDisposable< the output value type T> An abstract QueueDisposable implementation, extending an AtomicInteger, that defaults all unnecessary Queue methods to throw UnsupportedOperationException.
public abstract class	BasicQueueDisposable< the output value type T> An abstract QueueDisposable implementation that defaults all unnecessary Queue methods to throw UnsupportedOperationException.
public class	BiConsumerSingleObserver<T>
public abstract class	BlockingBaseObserver<T>
public class	BlockingDisposableMultiObserver< the element type of the source T> Blocks until the upstream terminates and dispatches the outcome to the actual observer.
public class	BlockingFirstObserver< the value type T> Blocks until the upstream signals its first value or completes.
public class	BlockingLastObserver< the value type T> Blocks until the upstream signals its last value or completes.
public class	BlockingMultiObserver< the value type T> A combined Observer that awaits the success or error signal via a CountDownLatch.
public class	BlockingObserver<T>
public class	CallbackCompletableObserver
public class	ConsumerSingleObserver<T>
public class	DeferredScalarDisposable< the value type received and emitted T> Represents a fuseable container for a single value.
public abstract class	DeferredScalarObserver< the input value type T, the output value type R> A fuseable Observer that can generate 0 or 1 resulting value.
public class	DisposableAutoReleaseMultiObserver< the element type consumed T> Wraps lambda callbacks and when the upstream terminates or this (Single \| Maybe \| Completable) observer gets disposed, removes itself from a `io.reactivex.rxjava3.disposables.CompositeDisposable`.
public class	DisposableAutoReleaseObserver< the element type consumed T> Wraps lambda callbacks and when the upstream terminates or this observer gets disposed, removes itself from a `io.reactivex.rxjava3.disposables.CompositeDisposable`.
public class	DisposableLambdaObserver<T>
public class	EmptyCompletableObserver
public class	ForEachWhileObserver<T>
public class	FutureMultiObserver< the value type T> An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.
public class	FutureObserver< the value type T> An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.
public class	InnerQueuedObserver< the value type T> Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.
public class	LambdaObserver<T>
public abstract class	QueueDrainObserver< the source type to which this subscriber will be subscribed T, the value type in the queue U, the value type the child subscriber accepts V> Abstract base class for subscribers that hold another subscriber, a queue and requires queue-drain behavior.
pack-priv class	QueueDrainSubscriberPad0 Pads the header away from other fields.
pack-priv class	QueueDrainSubscriberPad2 Pads away the wip from the other fields.
pack-priv class	QueueDrainSubscriberWip The wip counter.
public class	ResumeSingleObserver< the value type T> A SingleObserver implementation used for subscribing to the actual SingleSource and replace the current Disposable in a parent AtomicReference.
public class	SafeCompletableObserver Wraps another `CompletableObserver` and catches exceptions thrown by its `onSubscribe`, `onError` or `onComplete` methods despite the protocol forbids it.
public class	SafeMaybeObserver< the element type of the sequence T> Wraps another `MaybeObserver` and catches exceptions thrown by its `onSubscribe`, `onSuccess`, `onError` or `onComplete` methods despite the protocol forbids it.
public class	SafeSingleObserver< the element type of the sequence T> Wraps another `SingleObserver` and catches exceptions thrown by its `onSubscribe`, `onSuccess` or `onError` methods despite the protocol forbids it.

Package io.reactivex.rxjava3.internal.observers

Interface Summary

Class Summary