网络请求有个问题就是取消操作。
在Rxjava1中，调用subscribe之后会返回Subscription,然后利用CompositeSubscription进行统一管理。
在Rxjava2中，调用subscribe之后，返回的则是Disposable，Disposable同样用CompositeDisposable进行统一管理。
在Rxjava1中，我们继承Subscriber，可以这么写。
class MySubscriber<T> extends Subscriber<T> {
@Override
public void onStart() {
//do sth
}
@Override
public void onCompleted() {
//do sth
}
@Override
public void onError(Throwable e) {
//do sth
}
@Override
public void onNext(T response) {
//do sth
}
}而在Rxjava2中，我们则要继承ResourceSubscriber，写法也有些修改
class MySubscriber<T> extends ResourceSubscriber<T> {
@Override
public void onStart() {
super.onStart();//这里要特别注意，不能忽略，我就因为没注意到这个，吃了不少的亏
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(T response) {
}
}然后要注意的就是FlowableOnSubscribe这个类，一般来说我们会这么写：
Flowable.create(new FlowableOnSubscribe<T>() {
@Override
public void subscribe(final FlowableEmitter<T> e) throws Exception {
try {
Response<T> response = call.execute();
e.onNext(response.body());
e.onComplete();
} catch (Exception exception) {
e.onError(exception);
e.onComplete();
}
}
}, BackpressureStrategy.BUFFER);但这样子就会有个错误，上面提到了CompositeDisposable这个要管理Disposable，如果我们取消了操作，那就极有可能会发生，InterruptedException异常，因为call还在继续执行，它执行完之后，就会调用 e.onNext(response.body());之类的方法，继而抛出异常，解决方案就是把上面的改写一下：
Flowable.create(new FlowableOnSubscribe<T>() {
@Override
public void subscribe(final FlowableEmitter<T> e) throws Exception {
//设置取消监听
e.setCancellable(new Cancellable() {
@Override
public void cancel() throws Exception {
if (!call.isCanceled()) {
call.cancel();
}
}
});
try {
Response<T> response = call.execute();
if (!e.isCancelled()) {
e.onNext(response.body());
e.onComplete();
}
} catch (Exception exception) {
if (!e.isCancelled()) {
e.onError(exception);
e.onComplete();
}
}
}
}, BackpressureStrategy.BUFFER);加入了取消监听以及取消判断就ok了，这样子的做法比Rxjava1要好，Rxjava1即使取消了订阅，请求却还会继续跑，这就不会了