4
A
回答
4
樣品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);
}
相關問題
- 1. rxJava停止觀察取消訂閱
- 2. RxJava訂閱阻擋觀察到
- 3. RxJava:如何從可觀察對象中提取對象?
- 4. 取消訂閱動態觀察對象
- 5. 淘汰賽訂閱觀察的對象
- 6. 訂閱可觀察內容
- 7. 訂閱可觀察輸入
- 8. 訂閱可觀察值
- 9. Knockout訂閱可觀察數組內的js對象中的observable
- 10. 訂閱可觀察對象時出現無效擴展錯誤
- 11. 按順序訂閱一系列可觀察對象
- 12. RxJava:從Nullable對象創建可觀察對象
- 13. RxJava:組合觀察對象忽略從
- 14. RxJava等待一個觀察者與訂閱者等待另一個觀察者與其他訂閱者
- 15. rxjava可觀察構圖
- 16. NetworkOnMainThreadException時可觀察subscrible rxjava
- 17. 基於可觀察性,從可觀察對象中選擇可觀察對象
- 18. RxJava Mockito何時 - 返回已解析的可觀察對象
- 19. 角2可觀察訂閱不工作
- 20. 等待可觀察訂閱Angelar2
- 21. Angular 2可觀察訂閱顯示undefined
- 22. 更新數據 - 可觀察訂閱
- 23. 訂閱子組件的可觀察(valueChanges)
- 24. 可觀察訂閱沒有被調用
- 25. 訂閱後添加可觀察序列
- 26. 無法訂閱可觀察的上newThread
- 27. 取消可觀察訂閱並等待觀察者完成
- 28. 出版物訂閱觀察
- 29. RxJava。閱讀文件以觀察
- 30. 如何使用可觀察過濾可觀察對象
http://reactivex.io/RxJava/javadoc/rx/Observable.html#subscribe(rx.Observer) – flakes
只是使用'Subject'對象作爲PARAM爲'Observable#subscribe' – flakes
問題是,我正在使用Observable –
krzysiek