90 lines
3.4 KiB
Java
90 lines
3.4 KiB
Java
package com.ubt.jimu.user.presenter;
|
|
|
|
import android.content.Context;
|
|
import com.thoughtworks.xstream.XStream;
|
|
import com.ubt.jimu.base.entities.FollowEntities;
|
|
import com.ubt.jimu.base.entities.PraiseBean;
|
|
import com.ubt.jimu.base.http.ApiResultException;
|
|
import com.ubt.jimu.base.http.IApiObserver;
|
|
import com.ubt.jimu.user.contract.PraiseContract$Presenter;
|
|
import com.ubt.jimu.user.contract.PraiseContract$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 PraisePresenter implements PraiseContract$Presenter {
|
|
private Context a;
|
|
private PraiseContract$View b;
|
|
private CompositeDisposable c;
|
|
|
|
public PraisePresenter(Context context, PraiseContract$View praiseContract$View) {
|
|
this.a = context;
|
|
this.b = praiseContract$View;
|
|
this.b.setPresenter(this);
|
|
this.c = new CompositeDisposable();
|
|
}
|
|
|
|
@Override // com.ubt.jimu.user.contract.PraiseContract$Presenter
|
|
public void addPraise(int i) {
|
|
UserRepository.a(i).compose(RxSchedulers.a()).subscribe(new IApiObserver<FollowEntities>(this.a) { // from class: com.ubt.jimu.user.presenter.PraisePresenter.2
|
|
@Override // com.ubt.jimu.base.http.IApiObserver, io.reactivex.Observer
|
|
/* renamed from: a, reason: merged with bridge method [inline-methods] */
|
|
public void onNext(FollowEntities followEntities) {
|
|
super.onNext(followEntities);
|
|
PraisePresenter.this.b.a(followEntities);
|
|
}
|
|
|
|
@Override // com.ubt.jimu.base.http.IApiObserver
|
|
public void onApiError(ApiResultException apiResultException) {
|
|
PraisePresenter.this.b.b(apiResultException.getMessage());
|
|
}
|
|
|
|
@Override // com.ubt.jimu.base.http.IApiObserver, io.reactivex.Observer
|
|
public void onSubscribe(Disposable disposable) {
|
|
super.onSubscribe(disposable);
|
|
PraisePresenter.this.c.b(disposable);
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // com.ubtech.presenter.BasePresenter
|
|
public void subscribe() {
|
|
a(this.b.d(), this.b.e(), XStream.PRIORITY_VERY_HIGH);
|
|
}
|
|
|
|
@Override // com.ubtech.presenter.BasePresenter
|
|
public void unSubscribe() {
|
|
this.c.dispose();
|
|
this.c.a();
|
|
}
|
|
|
|
public void a(long j, int i, int i2) {
|
|
this.b.a();
|
|
UserRepository.a(j, i, i2).compose(RxSchedulers.a()).subscribe(new Observer<List<PraiseBean.Praise>>() { // from class: com.ubt.jimu.user.presenter.PraisePresenter.1
|
|
@Override // io.reactivex.Observer
|
|
/* renamed from: a, reason: merged with bridge method [inline-methods] */
|
|
public void onNext(List<PraiseBean.Praise> list) {
|
|
PraisePresenter.this.b.q(list);
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onComplete() {
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onError(Throwable th) {
|
|
PraisePresenter.this.b.b("");
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onSubscribe(Disposable disposable) {
|
|
PraisePresenter.this.c.b(disposable);
|
|
}
|
|
});
|
|
}
|
|
}
|