RxJava 2 2.2.21 · io.reactivex.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
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	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	DisposableLambdaObserver<T>
public class	EmptyCompletableObserver
public class	ForEachWhileObserver<T>
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	FutureSingleObserver< 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	SubscriberCompletableObserver<T>

Package io.reactivex.internal.observers

Interface Summary

Class Summary