RxJava UnicastSubject Sınıfı

Giriş

Açıklaması şöyle

UnicastSubject allows only a single subscriber and it emits all the items regardless of the time of subscription.

Örnek

Şöyle yaparız

Observable<Integer> observable = Observable.range(1, 5)
                .subscribeOn(Schedulers.io());


UnicastSubject<Integer> pSubject = UnicastSubject.create();
observable.subscribe(pSubject);


pSubject.subscribe(it -> System.out.println("onNext: " + it));

Çıktı olarak şunu alırız

onNext: 1

onNext: 2

onNext: 3

onNext: 4

onNext: 5