RXJava,每个循环都有

从一个 List<> 你可以用 Observable.fromIterable 操作员:

compositeDisposable.add(Observable.fromIterable(contents)
            .flatMap(content -> {
                return AppManagers.getContentManager()
                        .getScoreCardsAndUpdate(content.getId());
            })
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(scoreCards -> {
                ...
            }));

小精灵 :

您可以使用 zip 运算符将内容与GetScorecards合并,并在自定义对象中更新结果:

class Result {
    private String content;
    private String result;

    public Result(String content, String result) {
        this.content = content;
        this.result = result;
    }

    public String getContent() {
        return content;
    }

    public String getResult() {
        return result;
    }
}

public Observable<String> getScoreCardsAndUpdate(String content) {
    return Observable.just("result = " + content);
}

@Test
public void test() {
    List<String> contents = Arrays.asList("1", "2", "3", "4");

    Observable.fromIterable(contents)
            .flatMap(content -> {
                return Observable.zip(Observable.just(content), 
                        getScoreCardsAndUpdate(content), Result::new);
            })
            .subscribe(scoreCards -> {
                System.out.println("content = " + scoreCards.getContent() + 
                        ", " + scoreCards.getResult());
            });
}

您必须在一个线程中处理所有项目。您可以通过在rxjava2中添加一个调度程序来实现这一点。

.subscribeOn(Schedulers.single())

你的代码应该是

for (Content content : contents) {
            scoreCardDisposable = AppManagers.getContentManager()
                    .getScoreCardsAndUpdate(content.getId())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeOn(Schedulers.single())
                    .subscribe(scoreCards -> {
                       ...
                    });
            compositeDisposable.add(scoreCardDisposable);

       }