Package | Description |
---|---|
io.reactivex.subjects |
Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncSubject<T>
A Subject that emits the very last value followed by a completion event or the received error to Observers.
|
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>
A Subject that emits (multicasts) items to currently subscribed
Observer s and terminal events to current
or late Observer s. |
class |
ReplaySubject<T>
Replays events (in a configurable bounded or unbounded manner) to current and late
Observer s. |
class |
UnicastSubject<T>
A Subject that queues up events until a single
Observer subscribes to it, replays
those events to it until the Observer catches up and then switches to relaying events live to
this single Observer until this UnicastSubject terminates or the Observer unsubscribes. |
Modifier and Type | Method and Description |
---|---|
Subject<T> |
Subject.toSerialized()
Wraps this Subject and serializes the calls to the onSubscribe, onNext, onError and
onComplete methods, making them thread-safe.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.