RxJava - 从两个 Single observable 创建一个序列
RxJava - create a sequence from two Single observable
我有两个单身人士:
- 正在从 Facebook 获取用户信息数据。
- 使用从 Facebook 获取的信息在我的服务器上执行用户注册。
我希望第二个Single在第一个调用onSuccess之后立即开始,第二个Single取决于第一个的数据。
我正在寻找合适的运营商来实现这一目标。有什么推荐吗?
尝试平面图:
fetchUser
.flatmap(user -> registerUser(user))
.subscribe()
public Single<User> fetchUser() {...}
public Single<?> registerUser (User user) {...}
使用 zip
的其他方式
public Single<List<DataEntry>> getting(String rawSearchText) {
Single single1 = dbSearch(rawSearchText);
Single single2 = onlineSearch(rawSearchText);
return Single.zip(single1, single2, (b1, b2) -> CombineTwoLists(b1, b2))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
我有两个单身人士:
- 正在从 Facebook 获取用户信息数据。
- 使用从 Facebook 获取的信息在我的服务器上执行用户注册。
我希望第二个Single在第一个调用onSuccess之后立即开始,第二个Single取决于第一个的数据。 我正在寻找合适的运营商来实现这一目标。有什么推荐吗?
尝试平面图:
fetchUser
.flatmap(user -> registerUser(user))
.subscribe()
public Single<User> fetchUser() {...}
public Single<?> registerUser (User user) {...}
使用 zip
的其他方式 public Single<List<DataEntry>> getting(String rawSearchText) {
Single single1 = dbSearch(rawSearchText);
Single single2 = onlineSearch(rawSearchText);
return Single.zip(single1, single2, (b1, b2) -> CombineTwoLists(b1, b2))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}