RxJava如何訂閱可觀察對象

Question

文檔中提到，對象是觀察者並且可以訂閱觀察對象，但我找不到在代碼中執行此操作的方法。

在此先感謝！

Answer 1

樣品junit的代碼：

@Test 
public void shouldSubscribeToSubjectToObservable() throws InterruptedException { 
    Observable<Integer> observable = Observable.just(1, 2); 
    PublishSubject<Object> subject = PublishSubject.create(); 
    subject.subscribe(o -> { 
     System.out.println("o = " + o); 
    }); 

    observable.subscribe(subject); 

    Thread.sleep(1000); 
}