前言

RxJava系列文章
RxJava系列文章（一） - 网络图片加载水印一般写法
RxJava系列文章（二） - 网络图片添加水印RxJava写法
RxJava系列文章（三） - 线程调度切换源码分析
RxJava系列文章（四） - 普通观察者与RxJava的观察者
RxJava系列文章（五）- CopyOnWriteArrayList与ConcurrentLinkedQueue
RxJava系列文章（六）- new Handler()与new Handler(Looper.getMainLooper())区别
RxJava系列文章（七） - 你是否了解RxJava
RxJava系列文章（八） - RxPermission

1. 代码如下：

/**
 * Email: 2185134304@qq.com
 * Created by Novate 2018/6/23 12:11
 * Version 1.0
 * Params:
 * Description:
*/

public class MainActivity1 extends AppCompatActivity {


    private ImageView iv;


    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        iv = (ImageView) findViewById(R.id.iv);

        // 需求：给网络上的一张图片添加水印，显示到 ImageView 控件上
        // 1. 开启线程下载图片；
        // 2. 添加水印；
        // 3. 切换到主线程显示图片；

        Observable.just("http://img.taopic.com/uploads/allimg/130331/240460-13033106243430.jpg")
                .map(new Function<String, Bitmap>() {  // 事件变换：把 String - Bitmap
                    @Override
                    public Bitmap apply(@NonNull String urlPath) throws Exception {
                        URL url = new URL(urlPath);
                        HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
                        InputStream inputStream = urlConnection.getInputStream();
                        Bitmap bitmap = BitmapFactory.decodeStream(inputStream);
                        return bitmap;
                    }
                })
                .map(new Function<Bitmap, Bitmap>() {  // 事件变换：把 Bitmap - Bitmap 添加水印
                    @Override
                    public Bitmap apply(@NonNull Bitmap bitmap) throws Exception {
                        bitmap = createWatermark(bitmap, "RxJava2.0");
                        return bitmap;
                    }
                })
                .subscribeOn(Schedulers.io())  // subscribeOn以上所有操作全部在子线程中执行
                .observeOn(AndroidSchedulers.mainThread())  // observeOn以下操作全部在主线程中执行
                .subscribe(new Consumer<Bitmap>() {
                    @Override
                    public void accept(Bitmap bitmap) throws Exception {
                        iv.setImageBitmap(bitmap);
                    }
                });

    }


    private Bitmap createWatermark(Bitmap bitmap, String mark) {
        int w = bitmap.getWidth();
        int h = bitmap.getHeight();
        Bitmap bmp = Bitmap.createBitmap(w, h, Bitmap.Config.ARGB_8888);
        Canvas canvas = new Canvas(bmp);
        Paint p = new Paint();
        // 水印颜色
        p.setColor(Color.parseColor("#C5FF0000"));
        // 水印字体大小
        p.setTextSize(150);
        //抗锯齿
        p.setAntiAlias(true);
        //绘制图像
        canvas.drawBitmap(bitmap, 0, 0, p);
        //绘制文字
        canvas.drawText(mark, 0, h / 2, p);
        canvas.save(Canvas.ALL_SAVE_FLAG);
        canvas.restore();
        return bmp;
    }
}

分析以上代码可知：

1>：首先 用 map操作符：把 String类型url转为 Bitmap；
2>：然后 用 map操作符：把 Bitmap类型 转为 Bitmap；
3>：用 subscribeOn(Schedulers.io()) ：表示 subscribeOn(Schedulers.io()) 以上操作全部执行在子线程中；
4>：用 observeOn(AndroidSchedulers.mainThread())：表示 observeOn(AndroidSchedulers.mainThread()) 以下操作切换到 主线程，全部在主线程中执行；
5>：用 subscribe(new Consumer<Bitmap>(){}：显示图片即可；

2. RxJava特点

1>：优点：一条链子下来的，可读性比较高、扩展性、维护性；
2>：缺点：学习成本高，思想难以转换（基于事件流的思想）