rxjava在创建observable后添加项目

Question

我刚开始使用rxjava而且卡住了.也许我没有以正确的方式使用rxjava,但我需要Observable在创建后添加项目.所以我理解你可以只是打电话Observable.just("Some", "Items"),订阅者会收到它们,但是如果我有一个异步任务,我需要在任务完成后再添加一些项目呢？我找不到类似的东西Observable.addItems("Some", "More", "Items")

Answer 1

您可能需要的是主题 - http://reactivex.io/documentation/subject.html

它是Observer和Observable的对象,因此您可以订阅它并发出新项.例如 :

PublishSubject<String> subject = PublishSubject.create();
subject.subscribe(System.out::println);
subject.onNext("Item1");
subject.onNext("Item2");