Uses of Package
rx.internal.operators
Packages that use rx.internal.operators
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
Default wrappers and implementations for the base reactive consumer classes and interfaces;
utility classes for creating them from callbacks.
Classes extending the Observable base reactive class and implementing
the Observer interface at the same time (aka hot Observables).
-
Classes in rx.internal.operators used by rx.internal.operatorsClassDescriptionA solution to the "time gap" problem that occurs with
groupBy
andpivot
.The common state.An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.Contains the active child producers and the values to replay.Keeps track of the current request amount and the replay position for a child Subscriber.Base class for Subscribers that consume the entire upstream and signal zero or one element (or an error) in a backpressure honoring fashion.Holds a singleton instance of an empty Observable which is stateless and completes the child subscriber immediately.Holds a singleton instance of a never Observable which is stateless doesn't call any of the Subscriber's methods.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 creatingNotification
objects for everyonNext
andonCompleted
.The parent subscriber that forwards events and cleans up on a terminal state.Singleton instance via enum.Multicasts notifications coming through its input Subscriber view to its client Subscribers via lockstep backpressure mode.The subscriber that must be used for subscribing to the upstream source.A Producer and Subscription that wraps a child Subscriber and manages its backpressure requests along with its unsubscription from the parent class.Allows conversion of an Observable to a Single ensuring that exactly one item is emitted - no more and no less.Hides the identity of another observable.Reverses the effect ofOperatorMaterialize
by transforming the Notification objects emitted by a source Observable into the items or notifications they represent.Returns an Observable that emits all distinct items emitted by the source.Returns an Observable that emits all sequentially distinct items emitted by the source.Turns all of the notifications from an Observable intoonNext
emissions, and marks them with their original notification types withinNotification
objects.Flattens a list ofObservable
s into oneObservable
, without any transformation.The subscriber that observes Observables.An operator which drops all but the last received value in case the downstream doesn't request more.A terminable producer which emits the latest items on request.Instruct an Observable to pass control to another Observable (the return value of a function) rather than invokingonError
if it encounters an error.A Producer and Subscription that manages the request and unsubscription state of a child subscriber in thread-safe manner.Base class for bounded buffering with options to specify an enter and leave transforms and custom truncation behavior.A Producer and Subscription that manages the request and unsubscription state of a child subscriber in thread-safe manner.Represents a node in a bounded replay buffer's linked list.The interface for interacting with various buffering logic.If the Observable completes after emitting a single item that matches a predicate, return an Observable containing that item.Transforms an Observable that emits Observables into a single Observable that emits the items emitted by the most recently published of those Observables.Set up the timeout action on the first value.Set up the timeout action based on every valueReturns anObservable
that emits a single item, a list composed of all the items emitted by the sourceObservable
.Observes the source.Observes the source.Serialized access to the subject.Record to store the subject and the emission count.The immutable windowing state with one subject. -
Classes in rx.internal.operators used by rx.internal.utilClassDescriptionFor 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 everyonNext
andonCompleted
. -
Classes in rx.internal.operators used by rx.observersClassDescriptionFor 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 everyonNext
andonCompleted
. -
Classes in rx.internal.operators used by rx.subjectsClassDescriptionFor 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 everyonNext
andonCompleted
.