package com.ydl.ydlnet.client.observer; import io.reactivex.disposables.Disposable; /** * Created by haorui on 2019-09-02 . * Des: 常用 Observer */ public abstract class CommonObserver<T> extends BaseObserver<T> { /** * 失败回调 * * @param errorMsg */ protected abstract void onError(String errorMsg); /** * 成功回调 * * @param t */ protected abstract void onSuccess(T t); @Override public void doOnSubscribe(Disposable d) { } @Override public void doOnError(String errorMsg) { onError(errorMsg); } @Override public void doOnNext(T t) { onSuccess(t); } @Override public void doOnCompleted() { } }