package com.gh.download.cache;

import com.gh.gamecenter.BuildConfig;
import com.lightgame.utils.Utils;

import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public abstract class CacheObserver implements Observer<CacheInfo> {
    protected Disposable d;//可以用于取消注册的监听者
    protected CacheInfo cacheInfo;

    @Override
    public void onSubscribe(Disposable d) {
        this.d = d;
    }

    @Override
    public void onNext(CacheInfo cacheInfo) {
        this.cacheInfo = cacheInfo;
        if (BuildConfig.DEBUG) {
            Utils.log(cacheInfo.getProgress() + "-" + cacheInfo.getTotal());
        }
    }

    @Override
    public void onError(Throwable e) {
        e.printStackTrace();
    }

    @Override
    public void onComplete() {

    }
}