RxJava实战演示2，获取网络图片

本文参考老罗视频进行讲解

下载工具类封装：public class DownLoadUtils {

private OkHttpClient client;
public DownLoadUtils(){
client = new OkHttpClient();
}

/**
* 声明一个被观察者对象，作为结果返回
* @param path
* @return
*/
public Observable<byte[]> downLoadImage(String path){
return Observable.create(new Observable.OnSubscribe<byte[]>() {
@Override
public void call(Subscriber<? super byte[]> subscriber) {
if (!subscriber.isUnsubscribed()){
//访问网络操作
Request request = new Request.Builder().url(path).build();
client.newCall(request).enqueue(new Callback() {
@Override
public void onFailure(Call call, IOException e) {
subscriber.onError(e);
}

@Override
public void onResponse(Call call, Response response) throws IOException {
if (response.isSuccessful()) {
byte[] data = response.body().bytes();
if (data != null) {
subscriber.onNext(data);
}
}
subscriber.onCompleted();
}
});

}
}
});
}

}界面进行调用，只显示了核心代码：
utils = new DownLoadUtils();
button.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
//使用HTTP协议获取数据
utils.downLoadImage(PATH).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Subscriber<byte[]>() {
@Override
public void onCompleted() {
Log.i(TAG,"onCompleted");//对话框消失
}

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

@Override
public void onNext(byte[] bytes) {
Bitmap bitmap = BitmapFactory.decodeByteArray(bytes,0,bytes.length);//实际情况应该做图片处理，避免oom
imageView.setImageBitmap(bitmap);
}
});
}
});其中：subscribeOn表示被观察者即事件的生产者所执行的线程，一般为io线程进行耗时操作
    observeOn表示观察者，即事件的消耗者执行的线程，一般为UI线程主线程进行操作