UnicastSubjectExample.java

       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));