BlockingOperatorNext.NextObserver |
|
BufferUntilSubscriber |
A solution to the "time gap" problem that occurs with groupBy and pivot .
|
BufferUntilSubscriber.State |
The common state.
|
CachedObservable |
An observable which auto-connects to another observable, caches the elements
from that observable but allows terminating the connection and completing the cache.
|
CachedObservable.CacheState |
Contains the active child producers and the values to replay.
|
CachedObservable.ReplayProducer |
Keeps track of the current request amount and the replay position for a child Subscriber.
|
CompletableOnSubscribeConcat.CompletableConcatSubscriber.ConcatInnerSubscriber |
|
DeferredScalarSubscriber |
Base class for Subscribers that consume the entire upstream and signal
zero or one element (or an error) in a backpressure honoring fashion.
|
EmptyObservableHolder |
Holds a singleton instance of an empty Observable which is stateless and completes
the child subscriber immediately.
|
NeverObservableHolder |
Holds a singleton instance of a never Observable which is stateless doesn't
call any of the Subscriber's methods.
|
NotificationLite |
For use in internal operators that need something like materialize and dematerialize wholly within the
implementation of the operator but don't want to incur the allocation cost of actually creating
Notification objects for every onNext and
onCompleted .
|
OnSubscribeAmb.AmbSubscriber |
|
OnSubscribeAmb.Selection |
|
OnSubscribeCombineLatest.CombinerSubscriber |
|
OnSubscribeCombineLatest.LatestCoordinator |
|
OnSubscribeConcatMap.ConcatMapSubscriber |
|
OnSubscribeDetach.DetachSubscriber |
The parent subscriber that forwards events and cleans up on a terminal state.
|
OnSubscribeDetach.TerminatedProducer |
Singleton instance via enum.
|
OnSubscribeFromAsync.BaseAsyncEmitter |
|
OnSubscribeFromAsync.NoOverflowBaseAsyncEmitter |
|
OnSubscribePublishMulticast |
Multicasts notifications coming through its input Subscriber view to its
client Subscribers via lockstep backpressure mode.
|
OnSubscribePublishMulticast.ParentSubscriber |
The subscriber that must be used for subscribing to the upstream source.
|
OnSubscribePublishMulticast.PublishProducer |
A Producer and Subscription that wraps a child Subscriber and manages
its backpressure requests along with its unsubscription from the parent
class.
|
OnSubscribeSingle |
Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.
|
OperatorAsObservable |
Hides the identity of another observable.
|
OperatorDematerialize |
Reverses the effect of OperatorMaterialize by transforming the Notification objects
emitted by a source Observable into the items or notifications they represent.
|
OperatorDistinct |
Returns an Observable that emits all distinct items emitted by the source.
|
OperatorDistinctUntilChanged |
Returns an Observable that emits all sequentially distinct items emitted by the source.
|
OperatorEagerConcatMap.EagerInnerSubscriber |
|
OperatorEagerConcatMap.EagerOuterProducer |
|
OperatorEagerConcatMap.EagerOuterSubscriber |
|
OperatorGroupBy.GroupByProducer |
|
OperatorGroupBy.GroupBySubscriber |
|
OperatorGroupBy.GroupedUnicast |
|
OperatorGroupBy.State |
|
OperatorIgnoreElements |
|
OperatorMaterialize |
Turns all of the notifications from an Observable into onNext emissions, and marks
them with their original notification types within Notification objects.
|
OperatorMerge |
Flattens a list of Observable s into one Observable , without any transformation.
|
OperatorMerge.InnerSubscriber |
|
OperatorMerge.MergeProducer |
|
OperatorMerge.MergeSubscriber |
The subscriber that observes Observables.
|
OperatorOnBackpressureBuffer |
|
OperatorOnBackpressureDrop |
|
OperatorOnBackpressureLatest |
An operator which drops all but the last received value in case the downstream
doesn't request more.
|
OperatorOnBackpressureLatest.LatestEmitter |
A terminable producer which emits the latest items on request.
|
OperatorOnBackpressureLatest.LatestSubscriber |
|
OperatorOnErrorResumeNextViaFunction |
Instruct an Observable to pass control to another Observable (the return value of a function)
rather than invoking onError if it encounters an error.
|
OperatorPublish.InnerProducer |
A Producer and Subscription that manages the request and unsubscription state of a
child subscriber in thread-safe manner.
|
OperatorPublish.PublishSubscriber |
|
OperatorReplay.BoundedReplayBuffer |
Base class for bounded buffering with options to specify an
enter and leave transforms and custom truncation behavior.
|
OperatorReplay.InnerProducer |
A Producer and Subscription that manages the request and unsubscription state of a
child subscriber in thread-safe manner.
|
OperatorReplay.Node |
Represents a node in a bounded replay buffer's linked list.
|
OperatorReplay.ReplayBuffer |
The interface for interacting with various buffering logic.
|
OperatorReplay.ReplaySubscriber |
|
OperatorSerialize |
|
OperatorSingle |
If the Observable completes after emitting a single item that matches a
predicate, return an Observable containing that item.
|
OperatorSwitch |
Transforms an Observable that emits Observables into a single Observable that
emits the items emitted by the most recently published of those Observables.
|
OperatorSwitch.InnerSubscriber |
|
OperatorSwitch.SwitchSubscriber |
|
OperatorTimeoutBase |
|
OperatorTimeoutBase.FirstTimeoutStub |
Set up the timeout action on the first value.
|
OperatorTimeoutBase.TimeoutStub |
Set up the timeout action based on every value
|
OperatorToObservableList |
Returns an Observable that emits a single item, a list composed of all the items emitted by the
source Observable .
|
OperatorWindowWithObservable.SourceSubscriber |
Observes the source.
|
OperatorWindowWithObservableFactory.SourceSubscriber |
Observes the source.
|
OperatorWindowWithStartEndObservable.SerializedSubject |
Serialized access to the subject.
|
OperatorWindowWithTime.CountedSerializedSubject |
Record to store the subject and the emission count.
|
OperatorWindowWithTime.State |
The immutable windowing state with one subject.
|
OperatorWithLatestFromMany.WithLatestMainSubscriber |
|
OperatorZip.Zip |
|
OperatorZip.ZipProducer |
|
SingleOperatorOnErrorResumeNext |
|