/**
 * 
 */
package cn.strong.fastdfs.client.protocol.response;

import rx.Observable;
import rx.subjects.PublishSubject;

/**
 * 抽象接收器类
 * 
 * @author liulongbiao
 *
 */
public abstract class AbstractReceiver<T> implements Receiver<T> {
	protected PublishSubject<T> subject = PublishSubject.create();

	@Override
	public void tryError(Throwable ex) {
		subject.onError(ex);
	}

	@Override
	public Observable<T> observable() {
		return subject.asObservable();
	}
}

@@ -99,23 +99,22 @@
 ubjects.
-Publish
+Replay
 Subject;
@@ -241,23 +241,22 @@
 otected 
-Publish
+Replay
 Subject%3C
@@ -272,15 +272,14 @@
 t = 
-Publish
+Replay
 Subj

use ReplaySubject instead of PublishSubject