Package | Description |
---|---|
io.reactivex.internal.observers |
Class and Description |
---|
BasicIntQueueDisposable
An abstract QueueDisposable implementation, extending an AtomicInteger,
that defaults all unnecessary Queue methods to throw UnsupportedOperationException.
|
BlockingBaseObserver |
DeferredScalarDisposable
Represents a fuseable container for a single value.
|
InnerQueuedObserver
Subscriber that can fuse with the upstream and calls a support interface
whenever an event is available.
|
InnerQueuedObserverSupport
Interface to allow the InnerQueuedSubscriber to call back a parent
with signals.
|
Copyright © 2019. All rights reserved.