java - 来自具有异步等待回调的列表的 RxJava

Question

List<String> listExample = Arrays.asList("one", "two", "three");

想想我有字符串列表，并使用RxJava ( Observable.fromArray )

Observable.fromArray(ids.toArray(new String[ids.size()])).subscribe(new Consumer<String>() {
    @Override
    public void accept(@NonNull String s) throws Exception {

    }
});

这里认为每个字符串都有一个异步回调，一旦我收到该回调，它应该移动到下一个字符串。可以使用rxjava吗？

这是我当前拥有的代码，它不会等到回调正确!

for (String id : ids) {
    getMessage(id, new urlGenCallback() {
        @Override
        public void urlAndToken(String url, String token, String idx) {

        }
    });
}

谢谢你@Geoffrey Marizy

答案:Check Below有关 ConcatMap 的更多信息 Visit Here

Answer 1

您正在寻找concatMap运算符(operator)。关于此主题的完整文章:https://fernandocejas.com/2015/01/11/rxjava-observable-tranformation-concatmap-vs-flatmap/

将您的请求包装为 Observable，然后将其作为参数传递给 concatMap :

Observable.fromArray(ids.toArray(new String[ids.size()])).concatMap(/* your request returning an Observable */)