RxJava - tematy

Zgodnie z Reactive, podmiot może działać zarówno jako obserwowalny, jak i obserwator.

Temat jest rodzajem mostu lub serwera proxy, który jest dostępny w niektórych implementacjach ReactiveX, który działa zarówno jako obserwator, jak i jako obserwowalny. Ponieważ jest obserwatorem, może subskrybować jeden lub więcej Observable, a ponieważ jest Observable, może przechodzić przez obserwowane elementy, ponownie je emitując, a także może emitować nowe elementy.

Istnieją cztery rodzaje przedmiotów -

Sr.No. Opis tematu
1

Publish Subject

Emituje tylko te elementy, które są emitowane po czasie subskrypcji.

2 Replay Subject

Emituje wszystkie elementy emitowane przez źródło Observable, niezależnie od tego, kiedy zasubskrybował Observable.

3

Behavior Subject

Po subskrypcji emituje najnowszy element, a następnie kontynuuje emitowanie elementu emitowanego przez źródło Observable.

4

Async Subject

Emituje ostatni element emitowany przez źródło Observable po zakończeniu emisji.