RxJava 3 3.1.8 · io.reactivex.rxjava3.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.

Available subject classes with their respective base classes and consumer interfaces:

The available subject classes with their respective base classes and consumer interfaces.
Subject type	Base class	Consumer interface
`Subject` `AsyncSubject` `BehaviorSubject` `PublishSubject` `ReplaySubject` `UnicastSubject`	`Observable`	`Observer`
`SingleSubject`	`Single`	`SingleObserver`
`MaybeSubject`	`Maybe`	`MaybeObserver`
`CompletableSubject`	`Completable`	`CompletableObserver`

The backpressure-aware variants of the Subject class are called org.reactivestreams.Processors and reside in the io.reactivex.processors package.

Class Summary

Modifier and Type	Class and Description
public class	AsyncSubject< the value type T> A Subject that emits the very last value followed by a completion event or the received error to Observers.
public class	BehaviorSubject< the type of item expected to be observed by the Subject T> Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed `Observer`.
public class	CompletableSubject Represents a hot Completable-like source and consumer of events similar to Subjects.
public class	MaybeSubject< the value type received and emitted T> Represents a hot Maybe-like source and consumer of events similar to Subjects.
public class	PublishSubject< the type of items observed and emitted by the Subject T> A Subject that emits (multicasts) items to currently subscribed `Observer`s and terminal events to current or late `Observer`s.
public class	ReplaySubject< the value type T> Replays events (in a configurable bounded or unbounded manner) to current and late `Observer`s.
pack-priv class	SerializedSubject< the item value type T> Serializes calls to the Observer methods.
public class	SingleSubject< the value type received and emitted T> Represents a hot Single-like source and consumer of events similar to Subjects.
public abstract class	Subject< the item value type T> Represents an `Observer` and an `Observable` at the same time, allowing multicasting events from a single source to multiple child `Observer`s.
public class	UnicastSubject< the value type received and emitted by this Subject subclass 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` disposes.

Package io.reactivex.rxjava3.subjects

Class Summary