49 lines
2.0 KiB
Java
49 lines
2.0 KiB
Java
package com.ubt.jimu.community.presenter;
|
|
|
|
import android.content.Context;
|
|
import com.ubt.jimu.base.entities.CreativeListResultBean;
|
|
import com.ubt.jimu.community.contract.InspireActivityContract$Presenter;
|
|
import com.ubt.jimu.community.contract.InspireActivityContract$View;
|
|
import com.ubt.jimu.community.model.InspireModel;
|
|
import io.reactivex.Observer;
|
|
import io.reactivex.android.schedulers.AndroidSchedulers;
|
|
import io.reactivex.disposables.CompositeDisposable;
|
|
import io.reactivex.disposables.Disposable;
|
|
import io.reactivex.schedulers.Schedulers;
|
|
|
|
/* loaded from: classes.dex */
|
|
public class InspirePresenter implements InspireActivityContract$Presenter {
|
|
private InspireActivityContract$View a;
|
|
private CompositeDisposable b = new CompositeDisposable();
|
|
|
|
public InspirePresenter(Context context, InspireActivityContract$View inspireActivityContract$View) {
|
|
this.a = inspireActivityContract$View;
|
|
}
|
|
|
|
@Override // com.ubt.jimu.community.contract.InspireActivityContract$Presenter
|
|
public void a(int i, final int i2) {
|
|
this.a.c();
|
|
InspireModel.a(i).subscribeOn(Schedulers.b()).observeOn(AndroidSchedulers.a()).subscribe(new Observer<CreativeListResultBean>() { // from class: com.ubt.jimu.community.presenter.InspirePresenter.1
|
|
@Override // io.reactivex.Observer
|
|
/* renamed from: a, reason: merged with bridge method [inline-methods] */
|
|
public void onNext(CreativeListResultBean creativeListResultBean) {
|
|
InspirePresenter.this.a.a(creativeListResultBean, i2);
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onComplete() {
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onError(Throwable th) {
|
|
InspirePresenter.this.a.o();
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onSubscribe(Disposable disposable) {
|
|
InspirePresenter.this.b.b(disposable);
|
|
}
|
|
});
|
|
}
|
|
}
|