异步 – rxjava在创建observable后添加项目

发布时间：2020-12-14 06:00:42 所属栏目：Java 来源：网络整理

导读：我刚刚开始使用rx java,我被卡住了.也许我没有以正确的方式使用rxjava,但是我需要在创建后将其添加到Observable.所以我明白你可以调用Observable.just(“Some”,“Items”),订阅者将收到它们,但是如果我有一个异步任务,我需要在稍后的任务添加一些项目完了吗

我刚刚开始使用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");

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!