1

我正在使用 RxAndroid 库来处理使用订阅者/可观察模式的项目列表。我的问题是，当一个项目被处理时，有一个需要更新的进度条。但是在处理了 16 个项目之后，似乎 observable 没有调用 onNext 方法，直到处理完其余的项目（90）然后调用了 90 次 onNext 方法。为什么会这样？这可能是内存问题吗？

代码如下。

订户：

public void startSingleRecognition(int id, int position) {
    mAdapter.updateItemProgress(0, position);
    Uri imageUri = Uri.parse(getHpCard(id).getUrlImage());
    final int[] i = {0};
    mSubscription = mRecognitionUtils
            .getRecognitionObservable(imageUri, configurations)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(
                    abbyResult -> mAdapter.updateItemProgress(++i[0], position),
                    e -> e.printStackTrace(),
                    () ->  mAdapter.updateItemProgress(-1, position));

}

可观察的：

public Observable<AbbyResult> getRecognitionObservable(Uri imageUri,
        ArrayList<Configuration> configurations) {
    return Observable.from(configurations)
            .flatMap(
                    configuration -> Observable.just(recognize(imageUri, configuration, this)));
}

识别方法确实很难处理图像，我的第一个想法是这种方法会消耗大量内存，并且在所有方法调用完成之前，observable 无法将处理过的项目交付给订阅者。但我不确定，有人可以证实这一点吗？

谢谢！

4

1 回答 1

1

好吧，我想我已经解决了！问题是使用 flatMap 而不是 concatMap。这里解释得很好：http: //fernadocejas.com/2015/01/11/rxjava-observable-transformation-concatmap-vs-flatmap/

于 2016-01-18T16:10:18.510 回答