package com.ubt.jimu.user.presenter;

import android.content.Context;
import com.ubt.jimu.base.entities.Fans;
import com.ubt.jimu.user.contract.FansContract$Presenter;
import com.ubt.jimu.user.contract.FansContract$View;
import com.ubt.jimu.user.repository.UserRepository;
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: classes2.dex */
public class FansPresenter implements FansContract$Presenter {
    private FansContract$View a;
    private CompositeDisposable b;

    public FansPresenter(Context context, FansContract$View fansContract$View) {
        this.a = fansContract$View;
        this.a.setPresenter(this);
        this.b = new CompositeDisposable();
    }

    @Override // com.ubt.jimu.user.contract.FansContract$Presenter
    public void d(long j, long j2) {
        this.a.a();
        UserRepository.a(j, j2, this.a.e(), this.a.f()).compose(RxSchedulers.a()).subscribe(new Observer<List<Fans>>() { // from class: com.ubt.jimu.user.presenter.FansPresenter.1
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(List<Fans> list) {
                FansPresenter.this.a.g(list);
            }

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

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

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

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

    @Override // com.ubtech.presenter.BasePresenter
    public void unSubscribe() {
        this.b.dispose();
        this.b.a();
    }
}