@@ -0,0 +1,465 @@
+/**%0A * %0A */%0Apackage cn.strong.fastdfs.client.protocol.response;%0A%0Aimport rx.Observable;%0Aimport rx.subjects.PublishSubject;%0A%0A/**%0A * %E6%8A%BD%E8%B1%A1%E6%8E%A5%E6%94%B6%E5%99%A8%E7%B1%BB%0A * %0A * @author liulongbiao%0A *%0A */%0Apublic abstract class AbstractReceiver%3CT%3E implements Receiver%3CT%3E %7B%0A%09protected PublishSubject%3CT%3E subject = PublishSubject.create();%0A%0A%09@Override%0A%09public void tryError(Throwable ex) %7B%0A%09%09subject.onError(ex);%0A%09%7D%0A%0A%09@Override%0A%09public Observable%3CT%3E observable() %7B%0A%09%09return subject.asObservable();%0A%09%7D%0A%7D%0A

add AbstractReceiver