63 lines
2.0 KiB
Java
63 lines
2.0 KiB
Java
package com.ubt.jimu.user.presenter;
|
|
|
|
import android.content.Context;
|
|
import com.ubt.jimu.base.entities.Rank;
|
|
import com.ubt.jimu.user.contract.RankContract$Presenter;
|
|
import com.ubt.jimu.user.contract.RankContract$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 RankPresenter implements RankContract$Presenter {
|
|
private RankContract$View a;
|
|
private CompositeDisposable b;
|
|
|
|
public RankPresenter(Context context, RankContract$View rankContract$View) {
|
|
this.a = rankContract$View;
|
|
this.a.setPresenter(this);
|
|
this.b = new CompositeDisposable();
|
|
}
|
|
|
|
@Override // com.ubt.jimu.user.contract.RankContract$Presenter
|
|
public void c(long j) {
|
|
this.a.a();
|
|
UserRepository.b(j).compose(RxSchedulers.a()).subscribe(new Observer<List<Rank>>() { // from class: com.ubt.jimu.user.presenter.RankPresenter.1
|
|
@Override // io.reactivex.Observer
|
|
/* renamed from: a, reason: merged with bridge method [inline-methods] */
|
|
public void onNext(List<Rank> list) {
|
|
RankPresenter.this.a.l(list);
|
|
RankPresenter.this.a.onSuccess();
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onComplete() {
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onError(Throwable th) {
|
|
RankPresenter.this.a.onError();
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onSubscribe(Disposable disposable) {
|
|
RankPresenter.this.b.b(disposable);
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // com.ubtech.presenter.BasePresenter
|
|
public void subscribe() {
|
|
c(this.a.d());
|
|
}
|
|
|
|
@Override // com.ubtech.presenter.BasePresenter
|
|
public void unSubscribe() {
|
|
this.b.dispose();
|
|
this.b.a();
|
|
}
|
|
}
|