RxJava BehaviorSubject Sınıfı - En Son Yayınlanan Nesneyi Yeni Aboneye Gönderir

Giriş

Açıklaması şöyle

BehaviorSubject emits the most recent item at the time of their subscription and all items after that. 

Örnek 

Elimizde şöyle bir kod olsun

BehaviorSubject<Integer> pSubject = BehaviorSubject.create();
pSubject.onNext(0);


pSubject.subscribe(it -> System.out.println("Observer 1 onNext: " + it),
                  (Throwable error) -> { }, () -> {},
                  on1 -> System.out.println("Observer 1 onSubscribe"));

pSubject.onNext(1);
pSubject.onNext(2);


pSubject.subscribe(it -> System.out.println("Observer 2 onNext: " + it),
                  (Throwable error) -> { }, () -> {},
                  on1 -> System.out.println("Observer 2 onSubscribe"));

pSubject.onNext(3);
pSubject.onNext(4);

Çıktı olarak şunu alırız. 2 numaralı katılımcı abone olduğunda 2 değeri zaten yayınlanmıştı, ancak yine de duyabilir.

Observer 1 onSubscribe

Observer 1 onNext: 0

Observer 1 onNext: 1

Observer 1 onNext: 2

Observer 2 onSubscribe

Observer 2 onNext: 2

Observer 1 onNext: 3

Observer 2 onNext: 3

Observer 1 onNext: 4

Observer 2 onNext: 4