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.
|
Class and Description |
---|
AsyncSubject
A Subject that emits the very last value followed by a completion event or the received error to Observers.
|
BehaviorSubject
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed
Observer . |
CompletableSubject
Represents a hot Completable-like source and consumer of events similar to Subjects.
|
MaybeSubject
Represents a hot Maybe-like source and consumer of events similar to Subjects.
|
PublishSubject
A Subject that emits (multicasts) items to currently subscribed
Observer s and terminal events to current
or late Observer s. |
ReplaySubject
Replays events (in a configurable bounded or unbounded manner) to current and late
Observer s. |
SingleSubject
Represents a hot Single-like source and consumer of events similar to Subjects.
|
Subject
Represents an
Observer and an Observable at the same time, allowing
multicasting events from a single source to multiple child Observer s. |
UnicastSubject
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. |
Copyright © 2019. All rights reserved.