将 AsyncTask 转换为 RxAndroid

Question

我有以下方法 post 使用 otto 和 AsyncTask 响应 UI。

private static void onGetLatestStoryCollectionSuccess(final StoryCollection storyCollection, final Bus bus) {
    new AsyncTask<Void, Void, Void>() {
        @Override
        protected Void doInBackground(Void... params) {
            bus.post(new LatestStoryCollectionResponse(storyCollection));
            return null;
        }
    }.execute();
}

我需要帮助使用 RxAndroid 库.

将此 AsyncTask 转换为 RxJava

Answer 1

这是使用 RxJava 的文件下载任务示例

Observable<File> downloadFileObservable() {
    return Observable.create(new OnSubscribeFunc<File>() {
        @Override
        public Subscription onSubscribe(Observer<? super File> fileObserver) {
            try {
                byte[] fileContent = downloadFile();
                File file = writeToFile(fileContent);
                fileObserver.onNext(file);
                fileObserver.onCompleted();
            } catch (Exception e) {
                fileObserver.onError(e);
            }
            return Subscriptions.empty();
        }
    });
}

用法：

downloadFileObservable()
  .subscribeOn(Schedulers.newThread())
  .observeOn(AndroidSchedulers.mainThread())
  .subscribe(observer); // you can post your event to Otto here

这会在新线程上下载文件并在主线程上通知您。

OnSubscribeFunc 已弃用。代码更新为使用 OnSubscribe insted。有关详细信息，请参阅 issue 802 on Github.

Code from here.

Answer 2

不要使用 .create() 而是使用 .defer()

Observable<File> observable = Observable.defer(new Func0<Observable<File>>() {
  @Override public Observable<File> call() {

    File file = downloadFile();

    return Observable.just(file);
  }
});

要了解更多详细信息，请参阅 https://speakerdeck.com/dlew/common-rxjava-mistakes

Answer 3

在您的情况下，您可以使用 fromCallable。更少的代码和自动 onError 排放量。

Observable<File> observable = Observable.fromCallable(new Callable<File>() {
        @Override
        public File call() throws Exception {
            File file = downloadFile();
            return file;
        }
    });

使用 lambdas：

Observable<File> observable = Observable.fromCallable(() -> downloadFile());

将 AsyncTask 转换为 RxAndroid

Convert AsyncTask to RxAndroid

android

android-asynctask

rx-java

rx-android