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