我有多个要转换为RxJava的对AsyncTask的调用。 AsyncTask代码可以工作,但是我只想探索如何在RxJava中做到这一点?

(顺便说一句,我知道标题很烂)

它能做什么:


遍历MyImageButton(这只是一个POJO,不扩展ImageButton)列表
在每个MyImageButton上,获取其当前位图(通过getDrawable())
从URL获取图标。
在合并两个图像BitmapUtils.combine(...);
将此新组合的位图分配给ImageButton


如何将其转换为RxJava:

 for (MyImageButton myImageButton: myImageButtons) {
        final ImageButton imageButton = (ImageButton) findViewById(myImageButton.getImageButtonResId()); //getImageButtonResId holds a reference to some ImageButton
        final Bitmap bitmap = ((BitmapDrawable) imageButton.getDrawable()).getBitmap();

        new BindImageTask(imageButton, bitmap, myImageButton.getIconUrl()).execute();
 }


这是BindImageTask:

private class BindImageTask extends AsyncTask<Void, Void, Bitmap> {

    private WeakReference<Bitmap> srcBitmapWeakReference;
    private WeakReference<ImageButton> imageButtonWeakReference;
    private String dstIconUrl;

    BindImageTask(ImageButton imageButton, Bitmap srcBitmap, String dstIconUrl) {

        srcBitmapWeakReference = new WeakReference<>(srcBitmap);
        imageButtonWeakReference = new WeakReference<>(imageButton);
        this.dstIconUrl = dstIconUrl;
    }

    @Override
    protected Bitmap doInBackground(Void... params) {
        Bitmap srcBitmap = srcBitmapWeakReference.get();
        if (srcBitmap == null) return null;

        Bitmap dstBitmap = ImageLoader.getInstance().loadImageSync(dstIconUrl, new ImageSize(60, 60));
        if (dstBitmap == null) {
            return null;
        }

        return BitmapUtils.combineImage(srcBitmap, dstBitmap, PorterDuff.Mode.DST_OVER);

    }

    @Override
    protected void onPostExecute(Bitmap resultBitmap) {
        super.onPostExecute(resultBitmap);

        ImageButton imageButton = imageButtonWeakReference.get();

        if (imageButton != null && resultBitmap != null) {
            imageButton.setImageBitmap(resultBitmap);
        }

    }
}


现在,我尝试在此上使用RxJava,并且产生了RxJava的这种不好用法(它可以工作,但我知道有更好的方法):

 Observable<MyImageButton> myImageButtonObservable = Observable.from(myImageButtons);

    myImageButtonObservable

            .map(new Func1<MyImageButton, MyImageButton>() {
                @Override
                public MyImageButton call(MyImageButton myImageButton) {
                    final ImageButton imageButton = (ImageButton) findViewById(myImageButton.getDialButtonResId());
                    final Bitmap srcBitmap = ((BitmapDrawable) imageButton.getDrawable()).getBitmap();
                    final Bitmap dstBitmap = ImageLoader.getInstance().loadImageSync(myImageButton.getIcon(), new ImageSize(60, 60));
                    final Bitmap newBitmap =  BitmapUtils.combineImage(srcBitmap, dstBitmap, PorterDuff.Mode.DST_OVER);

                    ImageLoader.getInstance().getMemoryCache().put(myImageButton.getIconUrl() + "_compound", newBitmap);
                    return myImageButton;

                }
            })
            .onErrorReturn(new Func1<Throwable, MyImageButton>() {
                @Override
                public MyImageButton call(Throwable throwable) {
                    return null;
                }
            })
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Action1<MyImageButton>() {
                @Override
                public void call(MyImageButton myImageButton) {
                    if(myImageButton == null) {
                        return;
                    }
                    final ImageButton imageButton = (ImageButton) findViewById(myImageButton.getDialButtonResId());
                    imageButton.setImageBitmap(ImageLoader.getInstance().getMemoryCache().get(myImageButton.getIconUrl() + "_compound"));
                }
            });


我想发生的是:


不必将新组合的图像保存到ImageLoader的缓存中。
在订阅回调上,我想同时引用此新位图和MyImageButton,以便可以执行一个简单的myImageButton.setImageBitmap(newBitmap)。


我不想要的:


在MyImageButton类中具有位图引用(因为我以后必须对其进行序列化)。

最佳答案

第一种方式。使用助手类数据

创建类Data.java

public static class Data{
    private ImageButton imageButton;
    private Bitmap srcBitmap;
    private Bitmap dstBitmap;
    private Bitmap combinedBitmap;
    private String dstIconUrl;

    public Data(ImageButton imageButton, String iconUrl) {
        this.imageButton = imageButton;
        srcBitmap = ((BitmapDrawable) imageButton.getDrawable()).getBitmap();
        dstIconUrl = iconUrl;
    }

    public ImageButton getImageButton() {
        return imageButton;
    }

    public Bitmap getSrcBitmap() {
        return srcBitmap;
    }

    public Bitmap getDstBitmap(){
        return dstBitmap;
    }

    public String getDstIconUrl() {
        return dstIconUrl;
    }

    public Bitmap getCombinedBitmap(){
        return combinedBitmap;
    }

    public Data withImageButton(ImageButton btn){
        this.imageButton = btn;
        return this;
    }

    public Data withSrcBitmap(Bitmap bitmap){
        this.srcBitmap = bitmap;
        return this;
    }

    public Data withIconUrl(String url){
        this.dstIconUrl = url;
        return this;
    }

    public Data withDstBitmap(Bitmap bitmap){
        this.dstBitmap = bitmap;
        return this;
    }

    public Data withCombinedBitmap(Bitmap bitmap){
        this.combinedBitmap = bitmap;
        return this;
    }
}


Data类处理按钮:

Observable.from(myImageButtons)
        .map(new Func1<MyImageButton, Data>() {
            @Override
            public Data call(MyImageButton myImageButton) {
                return new Data(myImageButton, myImageButton.getIconUrl());
            }
        })
        .map(new Func1<Data, Data>() {
            @Override
            public Data call(Data data) {
                return data.withDstBitmap(ImageLoader.getInstance().loadImageSync(data.getDstIconUrl(), new ImageSize(60, 60)));
            }
        })
        .filter(new Func1<Data, Boolean>() {
            @Override
            public Boolean call(Data data) {
                return data.getDstBitmap() != null;
            }
        })
        .map(new Func1<Data, Data>() {
            @Override
            public Data call(Data data) {
                return data.withCombinedBitmap(BitmapUtils.combineImage(data.getSrcBitmap(), data.getDstBitmap(), PorterDuff.Mode.DST_OVER));
            }
        })
        .subscribeOn(Schedulers.computation())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(
                new Action1<Data>() {
                    @Override
                    public void call(Data data) {   //onNext
                        data.getImageButton().setImageBitmap(data.getCombinedBitmap());

                        //I recomend you to recycle old bitmaps if they no needed
                        data.getSrcBitmap().recycle();
                        data.getDstBitmap().recycle();
                        data.withSrcBitmap(null).withDstBitmap(null);

                        //Complex way to remove this bitmaps from cache
                        //See http://stackoverflow.com/a/19512974/1796309
                        //MemoryCacheUtils.removeFromCache(data.getDstBitmap(), ImageLoader.getInstance().getMemoryCache());
                        //DiscCacheUtils.removeFromCache(data.getDstBitmap(), ImageLoader.getInstance().getDiscCache());
                    }
                },
                new Action1<Throwable>() {
                    @Override
                    public void call(Throwable throwable) {     //onError
                        throwable.printStackTrace();
                    }
                },
                new Action0() {
                    @Override
                    public void call() {
                        //Simple way to clear ImageLoaderCache
                        ImageLoader.getInstance().clearMemoryCache();
                    }
                }
        );


或使用Lambda表达式:

Observable.from(myImageButtons)
        .map(myImageButton -> new Data(myImageButton, myImageButton.getIconUrl()))
        .map(data -> data.withDstBitmap(ImageLoader.getInstance().loadImageSync(data.getDstIconUrl(), new ImageSize(60, 60))))
        .filter(data -> data.getDstBitmap() != null)
        .map(data -> data.withCombinedBitmap(BitmapUtils.combineImage(data.getSrcBitmap(), data.getDstBitmap(), PorterDuff.Mode.DST_OVER)))
        .subscribeOn(Schedulers.computation())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(
                data -> {   //onNext
                    data.getImageButton().setImageBitmap(data.getCombinedBitmap());

                    //I recomend you to recycle old bitmaps if they no needed
                    data.getSrcBitmap().recycle();
                    data.getDstBitmap().recycle();
                    data.withSrcBitmap(null).withDstBitmap(null);

                    //Complex way to remove this bitmaps from cache
                    //See http://stackoverflow.com/a/19512974/1796309
                    //MemoryCacheUtils.removeFromCache(data.getDstBitmap(), ImageLoader.getInstance().getMemoryCache());
                    //DiscCacheUtils.removeFromCache(data.getDstBitmap(), ImageLoader.getInstance().getDiscCache());
                },
                throwable -> {     //onError
                    throwable.printStackTrace();
                },
                () -> {
                    //Simple way to clear ImageLoaderCache
                    ImageLoader.getInstance().clearMemoryCache();
                }
        );


第二种方式。反应性更强...

创建DST位图Observable

public Observable<Bitmap> getDstIconsFromImageButtonsByIconUrls(){
    return Observable.from(myImageButtons)
            .map(new Func1<MyImageButton, String>() {
                @Override
                public String call(MyImageButton myImageButton) {
                    return myImageButton.getIconUrl();
                }
            })
            .map(new Func1<String, Bitmap>() {
                @Override
                public Bitmap call(String s) {
                    return ImageLoader.getInstance().loadImageSync(url, new ImageSize(60, 60));
                }
            });
}


或使用Lambdas

public Observable<Bitmap> getDstIconsFromImageButtonsByIconUrls(){
    return Observable.from(myImageButtons)
            .map(myImageButton -> myImageButton.getIconUrl())
            .map(s -> ImageLoader.getInstance().loadImageSync(url, new ImageSize(60, 60)));
}


创建SRC位图Observable

public Observable<Bitmap> getSrcIcons(){
    return Observable.from(myImageButtons)
            .map(new Func1<MyImageButton, Bitmap>() {
                @Override
                public Bitmap call(MyImageButton myImageButton) {
                    return ((BitmapDrawable) myImageButton.getDrawable()).getBitmap();
                }
            });
}


或使用Lambdas

public Observable<Bitmap> getSrcIcons(){
    return Observable.from(myImageButtons)
            .map(myImageButton -> ((BitmapDrawable) myImageButton.getDrawable()).getBitmap());
}


使用运算符zip( ) link

    Observable
            .zip(
                    Observable.from(myImageButtons),
                    getDstIconsFromImageButtonsByIconUrls(),
                    getSrcIcons(),
                    new Func3<MyImageButton, Bitmap, Bitmap, MyImageButton>() {
                        @Override
                        public MyImageButton call(MyImageButton btn, Bitmap dstBitmap, Bitmap srcBitmap) {
                            if(dstBitmap != null){
                                btn.setImageBitmap(BitmapUtils.combineImage(srcBitmap, dstBitmap, PorterDuff.Mode.DST_OVER));

                                //recycle bitmaps if you don't need them
                                dstBitmap.recycle();
                                srcBitmap.recycle();
                            }
                            return btn;
                        }
                    })
    .subscribe(
            new Action1<MyImageButton>() {
                @Override
                public void call(MyImageButton myImageButton) {
                    //do nothing
                }
            },
            new Action1<Throwable>() {
                @Override
                public void call(Throwable throwable) {
                    throwable.printStackTrace();
                }
            },
            new Action0() {
                @Override
                public void call() {
                    ImageLoader.getInstance().clearMemoryCache();
                }
            });


或使用Lambdas

    Observable
            .zip(
                    Observable.from(myImageButtons),
                    getDstIconsFromImageButtonsByIconUrls(),
                    getSrcIcons(),
                    (btn, dstBitmap, srcBitmap) -> {
                        if(dstBitmap != null){
                            btn.setImageBitmap(BitmapUtils.combineImage(srcBitmap, dstBitmap, PorterDuff.Mode.DST_OVER));

                            //recycle bitmaps if you don't need them
                            dstBitmap.recycle();
                            srcBitmap.recycle();
                        }
                        return btn;
                    })
    .subscribe(
            myImageButton -> {
                //do nothing
            },
            throwable -> throwable.printStackTrace(),
            () -> ImageLoader.getInstance().clearMemoryCache());


附言

我没有测试这个例子,但是它们应该起作用。如果您有任何问题,请告诉我。

关于android - 将具有多个参数的AsyncTask转换为RxJava,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/31596419/

10-13 03:44