RxJava - Assuntos

Conforme Reactive, um Assunto pode atuar como Observável e Observador.

Um Assunto é uma espécie de ponte ou proxy que está disponível em algumas implementações do ReactiveX que atua tanto como um observador quanto como um Observável. Por ser um observador, pode inscrever-se em um ou mais Observáveis ​​e, por ser um Observável, pode passar pelos itens que observa reemitindo-os e também pode emitir novos itens.

Existem quatro tipos de assuntos -

Sr. Não. Assunto e descrição
1

Publish Subject

Emite apenas os itens que são emitidos após o tempo de assinatura.

2 Replay Subject

Emite todos os itens emitidos pela fonte Observable, independentemente de quando ela assinou o Observable.

3

Behavior Subject

Após a assinatura, emite o item mais recente e, em seguida, continua a emitir o item emitido pela fonte Observável.

4

Async Subject

Emite o último item emitido pela fonte Observável após completar a emissão.