RxJava - Soggetti

Secondo il Reactive, un Soggetto può agire sia come Osservabile che come Osservatore.

Un Soggetto è una sorta di bridge o proxy disponibile in alcune implementazioni di ReactiveX che agisce sia come osservatore che come osservabile. Poiché è un osservatore, può iscriversi a uno o più osservabili e, poiché è un osservabile, può passare attraverso gli elementi che osserva riemettendoli e può anche emettere nuovi elementi.

Esistono quattro tipi di soggetti:

Sr.No. Oggetto e descrizione
1

Publish Subject

Emette solo quegli elementi che vengono emessi dopo il momento dell'abbonamento.

2 Replay Subject

Emette tutti gli elementi emessi dalla sorgente Observable indipendentemente da quando ha sottoscritto Observable.

3

Behavior Subject

Al momento dell'abbonamento, emette l'elemento più recente, quindi continua a emettere l'elemento emesso dalla fonte Observable.

4

Async Subject

Emette l'ultimo elemento emesso dalla sorgente Observable dopo che ha completato l'emissione.