RxJava

http://gank.io/post/560e15be2dca930e00da1083#toc_1

看过的最好的RxJava的文章，收藏备用。

Observable --->subscribe--->Observer

同步的Rxjava观察者模式

int drawableRes = ...;
ImageView imageView = ...;
Observable.create(new OnSubscribe<Drawable>() {
    @Override
    public void call(Subscriber<? super Drawable> subscriber) {
        Drawable drawable = getTheme().getDrawable(drawableRes));
        subscriber.onNext(drawable);
        subscriber.onCompleted();
    }
}).subscribe(new Observer<Drawable>() {
    @Override
    public void onNext(Drawable drawable) {
        imageView.setImageDrawable(drawable);
    }

    @Override
    public void onCompleted() {
    }

    @Override
    public void onError(Throwable e) {
        Toast.makeText(activity, "Error!", Toast.LENGTH_SHORT).show();
    }
});

线程控制
subscribeOn() 和 observeOn()
subscribeOn()表示被观察者处理数据所在的线程。
observeOn()表示观察者处理回调的线程。

图片.png