需要帮助将 AsyncTask 转换为 RxJava

Question

我今天深入研究了 RxJava。

我有一个将图像转换为位图并将其设置为 Imageview 的 AsyncTask。

我想将我的 AsyncTask 转换为 RxJava

这是我在下面工作的 AsyncTask：

String imageurl = "http://example.com/image.jpg";

new AsyncTask<String, Void, Void>() {
            Bitmap theBitmap = null;
            @Override
            protected Void doInBackground(String... params) {
                String TAG = "Message: ";

                try {
                    theBitmap = Glide.
                            with(mContext).
                            load(mValues.get(params[0]).
                            asBitmap().
                            into(-1, -1).
                            get();

                } catch (final ExecutionException e) {
                    Log.e(TAG, e.getMessage());
                } catch (final InterruptedException e) {
                    Log.e(TAG, e.getMessage());
                } catch (final NullPointerException e) {
                    Log.e(TAG, e.getMessage());
                }
                return null;
            }
            @Override
            protected void onPostExecute(Void dummy) {
                if (null != theBitmap) {
                    ImageView mImageView = (ImageView) findViewById(R.id.image);
                    mImageView.setImageBitmap(theBitmap);
                }
            }
        }.execute(imageurl);

我知道我想提供我尝试过的代码，但我在尝试围绕 RxJava 时遇到问题。我只是需要一些东西开始。

我看到了这个示例代码，它使用 Just where It 将整数传递给 onNext() 函数。 http://reactivex.io/documentation/operators/just.html

Observable.just(1, 2, 3)
          .subscribe(new Subscriber<Integer>() {
        @Override
        public void onNext(Integer item) {
            System.out.println("Next: " + item);
        }

        @Override
        public void onError(Throwable error) {
            System.err.println("Error: " + error.getMessage());
        }

        @Override
        public void onCompleted() {
            System.out.println("Sequence complete.");
        }
    });

请问，如何转换这段代码，以便像 AsyncTask 一样使用它

Answer 1

类似这样的：

mSubscription = Observable.defer(new Func0<Observable<Bitmap>>() {
    @Override
    public Observable<Bitmap> call() {
        return Observable.just(getBitmap(imageurl));
    }
})
        .filter(new Func1<Bitmap, Boolean>() {
            @Override
            public Boolean call(Bitmap bitmap) {
                return bitmap != null;
            }
        })
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<Bitmap>() {
            @Override
            public void onCompleted() {}

            @Override
            public void onError(Throwable throwable) {
                Log.e(TAG, e.getMessage());
            }

            @Override
            public void onNext(Bitmap bitmap) {
                ImageView mImageView = (ImageView) findViewById(R.id.image);
                mImageView.setImageBitmap(bitmap);
            }
        });

/* later in onDestroy(), onStop(), etc */
if (mSubscription != null && !mSubscription.isUnsubscribed()) {
    mSubscription.unsubscribe();
}