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 回答