我刚刚开始使用rx
java,我被卡住了.也许我没有以正确的方式使用rxjava,但是我需要在创建后将其添加到Observable.所以我明白你可以调用Observable.just(“Some”,“Items”),订阅者将收到它们,但是如果我有一个异步任务,我需要在稍后的任务添加一些项目完了吗？我找不到像Observable.addItems(“Some”,“More”,“Items”)的任何东西
解决方法
你可能需要的是主题 –
http://reactivex.io/documentation/subject.html
它是一个对象,既是Observer和Observable,所以你可以订阅它并发出新的项目.例如 ：
PublishSubject<String> subject = PublishSubject.create();
subject.subscribe(System.out::println);
subject.onNext("Item1");
subject.onNext("Item2");
