Package | Description |
---|---|
rx.internal.operators |
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
|
rx.subjects |
Classes extending the Observable base reactive class and implementing
the Observer interface at the same time (aka hot Observables).
|
Modifier and Type | Class and Description |
---|---|
class |
BufferUntilSubscriber<T>
A solution to the "time gap" problem that occurs with
groupBy and pivot . |
Constructor and Description |
---|
OperatorMulticast(Observable<? extends T> source,
Func0<? extends Subject<? super T,? extends R>> subjectFactory) |
Modifier and Type | Class and Description |
---|---|
class |
AsyncSubject<T>
Subject that publishes only the last item observed to each
Observer once the source Observable
has completed. |
class |
BehaviorSubject<T>
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed
Observer . |
class |
PublishSubject<T>
Subject that, once an
Observer has subscribed, emits all subsequently observed items to the
subscriber. |
class |
ReplaySubject<T>
Subject that buffers all items it observes and replays them to any
Observer that subscribes. |
class |
SerializedSubject<T,R>
Wraps a
Subject so that it is safe to call its various on methods from different threads. |
class |
TestSubject<T>
A variety of Subject that is useful for testing purposes.
|
class |
UnicastSubject<T>
A Subject variant which buffers events until a single Subscriber arrives and replays them to it
and potentially switches to direct delivery once the Subscriber caught up and requested an unlimited
amount.
|
Constructor and Description |
---|
SerializedSubject(Subject<T,R> actual) |
Copyright © 2017. All rights reserved.