我正在使用 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 无法将处理过的项目交付给订阅者。但我不确定,有人可以证实这一点吗?
谢谢!