Package | Description |
---|---|
rx.internal.operators |
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
|
Class and Description |
---|
BufferUntilSubscriber
A solution to the "time gap" problem that occurs with
groupBy and pivot . |
CachedObservable
An observable which auto-connects to another observable, caches the elements
from that observable but allows terminating the connection and completing the cache.
|
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.
|
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.
|
OperatorGroupBy.GroupBySubscriber |
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. |
OperatorOnBackpressureBuffer |
OperatorOnBackpressureDrop |
OperatorOnBackpressureLatest
An operator which drops all but the last received value in case the downstream
doesn't request more.
|
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. |
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.
|
OperatorToObservableList
Returns an
Observable that emits a single item, a list composed of all the items emitted by the
source Observable . |
SingleOperatorOnErrorResumeNext |
Copyright © 2017. All rights reserved.