package com.dayu.pipirrapp.net.subscribers;
|
|
import android.content.Context;
|
|
import androidx.annotation.NonNull;
|
|
import io.reactivex.rxjava3.core.Observer;
|
import io.reactivex.rxjava3.disposables.Disposable;
|
|
|
/**
|
* Created by zuoxiao on 2017/8/11.
|
*/
|
|
public abstract class BaseProgressSubscriber<T> implements Observer<T> {
|
|
|
public BaseProgressSubscriber() {
|
|
}
|
|
|
@Override
|
public void onSubscribe(@NonNull Disposable d) {
|
onMyStart(d);
|
}
|
|
// @Override
|
// public void onSubscribe() {
|
//
|
// }
|
|
@Override
|
public void onComplete() {
|
onMyCompleted();
|
onCloose();
|
}
|
|
@Override
|
public void onError(Throwable e) {
|
onMyError(e);
|
onCloose();
|
}
|
|
@Override
|
public void onNext(T t) {
|
onMyNext(t);
|
}
|
|
public abstract void onMyCompleted();
|
|
public abstract void onMyError(Throwable e);
|
|
public abstract void onMyNext(T t);
|
|
public abstract void onMyStart(Disposable d);
|
|
public abstract void onCloose();
|
|
public abstract BaseProgressSubscriber iniData(Context context, boolean hideLoading, SubscriberListener<T> mSubscriberListener);
|
|
public BaseProgressSubscriber initProgressSubscriber(Context context, boolean hideLoading, SubscriberListener<T> mSubscriberListener) {
|
return iniData(context, hideLoading, mSubscriberListener);
|
}
|
}
|