package com.ubt.jimu.discover.presenter;

import android.content.Context;
import com.ubt.jimu.base.download.Downloader;
import com.ubt.jimu.base.entities.Story;
import com.ubt.jimu.discover.CourseRepository;
import com.ubt.jimu.discover.contract.StoryContract$Presenter;
import com.ubt.jimu.discover.contract.StoryContract$View;
import com.ubt.jimu.utils.RxSchedulers;
import io.reactivex.Observer;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.disposables.Disposable;
import java.util.List;

/* loaded from: classes.dex */
public class StoryPresenter implements StoryContract$Presenter {
    private StoryContract$View a;
    private CompositeDisposable b = new CompositeDisposable();

    public StoryPresenter(Context context, StoryContract$View storyContract$View) {
        this.a = storyContract$View;
        this.a.setPresenter(this);
    }

    @Override // com.ubtech.presenter.BasePresenter
    public void subscribe() {
        a();
    }

    public void a() {
        CourseRepository.a().compose(RxSchedulers.a()).subscribe(new Observer<List<Story>>() { // from class: com.ubt.jimu.discover.presenter.StoryPresenter.1
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(List<Story> list) {
                StoryPresenter.this.a.o(list);
            }

            @Override // io.reactivex.Observer
            public void onComplete() {
            }

            @Override // io.reactivex.Observer
            public void onError(Throwable th) {
            }

            @Override // io.reactivex.Observer
            public void onSubscribe(Disposable disposable) {
                StoryPresenter.this.b.b(disposable);
            }
        });
    }

    @Override // com.ubt.jimu.discover.contract.StoryContract$Presenter
    public void a(Story story) {
        this.a.showCurrentTask(Downloader.downloadStarCourse(story, new Downloader.IDownloadJimuRobotListener() { // from class: com.ubt.jimu.discover.presenter.StoryPresenter.2
            @Override // com.ubt.jimu.base.download.Downloader.IDownloadJimuRobotListener
            public void onFailed() {
                StoryPresenter.this.a.onDownloadFail();
            }

            @Override // com.ubt.jimu.base.download.Downloader.IDownloadJimuRobotListener
            public void onPrepareStart() {
                StoryPresenter.this.a.onDownloadStart();
            }

            @Override // com.ubt.jimu.base.download.Downloader.IDownloadJimuRobotListener
            public void onProgress(int i, int i2, int i3) {
                StoryPresenter.this.a.onProgressChange(i3);
            }

            @Override // com.ubt.jimu.base.download.Downloader.IDownloadJimuRobotListener
            public void onSuccess() {
                StoryPresenter.this.a.a0();
            }
        }));
    }
}