59 lines
2.3 KiB
Java
59 lines
2.3 KiB
Java
package com.ubt.jimu.community.activity.presenter;
|
|
|
|
import android.content.Context;
|
|
import com.ubt.jimu.R;
|
|
import com.ubt.jimu.base.entities.Award;
|
|
import com.ubt.jimu.community.activity.contract.AwardSettingContract$Presenter;
|
|
import com.ubt.jimu.community.activity.contract.AwardSettingContract$View;
|
|
import com.ubt.jimu.community.activity.repository.ActivityRepository;
|
|
import com.ubt.jimu.utils.NetWorkUtil;
|
|
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 AwardSettingPresenter implements AwardSettingContract$Presenter {
|
|
private Context a;
|
|
private AwardSettingContract$View b;
|
|
private CompositeDisposable c;
|
|
|
|
public AwardSettingPresenter(Context context, AwardSettingContract$View awardSettingContract$View) {
|
|
this.a = context;
|
|
this.b = awardSettingContract$View;
|
|
this.b.setPresenter(this);
|
|
this.c = new CompositeDisposable();
|
|
}
|
|
|
|
@Override // com.ubt.jimu.community.activity.contract.AwardSettingContract$Presenter
|
|
public void a(long j) {
|
|
if (!NetWorkUtil.b(this.a)) {
|
|
this.b.a(this.a.getString(R.string.network_error));
|
|
} else {
|
|
this.b.a();
|
|
ActivityRepository.c(j).compose(RxSchedulers.a()).subscribe(new Observer<List<Award>>() { // from class: com.ubt.jimu.community.activity.presenter.AwardSettingPresenter.1
|
|
@Override // io.reactivex.Observer
|
|
/* renamed from: a, reason: merged with bridge method [inline-methods] */
|
|
public void onNext(List<Award> list) {
|
|
AwardSettingPresenter.this.b.p(list);
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onComplete() {
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onError(Throwable th) {
|
|
AwardSettingPresenter.this.b.a(th.getMessage());
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onSubscribe(Disposable disposable) {
|
|
AwardSettingPresenter.this.c.b(disposable);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
}
|