package com.linxiao.framework.rx;

import io.reactivex.annotations.NonNull;
import io.reactivex.observers.DisposableObserver;

/**
 * RxJava 可取消订阅的订阅类
 * <p>默认订阅对象实现，可以有选择的实现方法</p>
 *
 * Created by linxiao on 2017/7/2.
 */
public class RxSubscriber<T> extends DisposableObserver<T> {
    
    @Override
    public void onNext(@NonNull T t) {
        
    }
    
    @Override
    public void onError(@NonNull Throwable e) {
        
    }
    
    @Override
    public void onComplete() {
        
    }
}

@@ -28,16 +28,97 @@
 rk.rx;%0A%0A
+import org.reactivestreams.Subscriber;%0Aimport org.reactivestreams.Subscription;%0A%0A
 import i
@@ -356,22 +356,111 @@
 rver%3CT%3E 
-%7B%0A    
+implements Subscriber%3CT%3E %7B%0A%0A    @Override%0A    public void onSubscribe(Subscription s) %7B%0A%0A    %7D%0A
 %0A    @Ov

optimize RxSubscriber