285 lines
8.9 KiB
Java
285 lines
8.9 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||
|
|
import o.C3340avh;
|
||
|
|
import o.ZI;
|
||
|
|
import o.wRi;
|
||
|
|
|
||
|
|
/* renamed from: o.avh, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public class C3340avh extends ZI<InterfaceC9113ddb> {
|
||
|
|
private tPx a;
|
||
|
|
public C16334nZ b;
|
||
|
|
private AtomicBoolean c;
|
||
|
|
public C0367Fb d;
|
||
|
|
public C0476Hk e;
|
||
|
|
private gRO g;
|
||
|
|
private C16319nT h;
|
||
|
|
private ZBH i;
|
||
|
|
|
||
|
|
@InterfaceC13391fZD
|
||
|
|
public C3340avh(C16903sI c16903sI, ZBH zbh, C16319nT c16319nT, gRO gro, C16334nZ c16334nZ) {
|
||
|
|
super(c16903sI);
|
||
|
|
this.i = zbh;
|
||
|
|
this.h = c16319nT;
|
||
|
|
this.c = new AtomicBoolean(false);
|
||
|
|
this.g = gro;
|
||
|
|
this.b = c16334nZ;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
/* renamed from: o.avh$RVV */
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public final class RVV extends wRi.LWm<rYB> {
|
||
|
|
private C3340avh d;
|
||
|
|
|
||
|
|
RVV(C3340avh c3340avh) {
|
||
|
|
this.d = c3340avh;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final /* synthetic */ void onNext(Object obj) {
|
||
|
|
final rYB ryb = (rYB) obj;
|
||
|
|
C3340avh c3340avh = this.d;
|
||
|
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.avu
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
((InterfaceC9113ddb) obj2).e();
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3340avh.f != 0) {
|
||
|
|
ieS.e(c3340avh.f);
|
||
|
|
}
|
||
|
|
if (ryb.d != null && !ryb.d.isEmpty()) {
|
||
|
|
C3340avh c3340avh2 = this.d;
|
||
|
|
ZI.IeS ieS2 = new ZI.IeS(this, ryb) { // from class: o.avp
|
||
|
|
private rYB a;
|
||
|
|
private C3340avh.RVV c;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
InterfaceC9113ddb interfaceC9113ddb = (InterfaceC9113ddb) obj2;
|
||
|
|
interfaceC9113ddb.b(this.c.d.h.d(this.a));
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.c = this;
|
||
|
|
this.a = ryb;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3340avh2.f != 0) {
|
||
|
|
ieS2.e(c3340avh2.f);
|
||
|
|
}
|
||
|
|
this.d.a = ryb.b;
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if (this.d.e.f8200o != null) {
|
||
|
|
C3340avh c3340avh3 = this.d;
|
||
|
|
ZI.IeS ieS3 = new ZI.IeS(this) { // from class: o.avt
|
||
|
|
private C3340avh.RVV e;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
((InterfaceC9113ddb) obj2).d(this.e.d.e.f8200o);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.e = this;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3340avh3.f != 0) {
|
||
|
|
ieS3.e(c3340avh3.f);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if (this.d.g.d.a() != xKJ.ALL_REWARDS || this.d.g.d.d() != EnumC5365brf.POPULARITY) {
|
||
|
|
C3340avh c3340avh4 = this.d;
|
||
|
|
ZI.IeS ieS4 = new ZI.IeS() { // from class: o.avw
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
((InterfaceC9113ddb) obj2).a();
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3340avh4.f != 0) {
|
||
|
|
ieS4.e(c3340avh4.f);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
C3340avh c3340avh5 = this.d;
|
||
|
|
ZI.IeS ieS5 = new ZI.IeS() { // from class: o.avv
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
((InterfaceC9113ddb) obj2).d();
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3340avh5.f != 0) {
|
||
|
|
ieS5.e(c3340avh5.f);
|
||
|
|
}
|
||
|
|
C3340avh c3340avh6 = this.d;
|
||
|
|
C3357avy c3357avy = new C3357avy();
|
||
|
|
if (c3340avh6.f != 0) {
|
||
|
|
c3357avy.e(c3340avh6.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final void onComplete() {
|
||
|
|
C3340avh.e(this.d);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final void onError(Throwable th) {
|
||
|
|
if (this.d.i(th)) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
C3340avh.h(this.d);
|
||
|
|
C3340avh c3340avh = this.d;
|
||
|
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.avA
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
((InterfaceC9113ddb) obj).b();
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3340avh.f != 0) {
|
||
|
|
ieS.e(c3340avh.f);
|
||
|
|
}
|
||
|
|
C3340avh c3340avh2 = this.d;
|
||
|
|
C3357avy c3357avy = new C3357avy();
|
||
|
|
if (c3340avh2.f != 0) {
|
||
|
|
c3357avy.e(c3340avh2.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* renamed from: o.avh$IeS */
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public class IeS extends wRi.LWm<rYB> {
|
||
|
|
private C3340avh c;
|
||
|
|
|
||
|
|
public IeS(C3340avh c3340avh) {
|
||
|
|
this.c = c3340avh;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final /* synthetic */ void onNext(Object obj) {
|
||
|
|
final rYB ryb = (rYB) obj;
|
||
|
|
C3340avh c3340avh = this.c;
|
||
|
|
C3346avn c3346avn = new C3346avn();
|
||
|
|
if (c3340avh.f != 0) {
|
||
|
|
c3346avn.e(c3340avh.f);
|
||
|
|
}
|
||
|
|
C3340avh c3340avh2 = this.c;
|
||
|
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.avs
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
((InterfaceC9113ddb) obj2).l();
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3340avh2.f != 0) {
|
||
|
|
ieS.e(c3340avh2.f);
|
||
|
|
}
|
||
|
|
C3340avh c3340avh3 = this.c;
|
||
|
|
ZI.IeS ieS2 = new ZI.IeS(this, ryb) { // from class: o.avq
|
||
|
|
private rYB b;
|
||
|
|
private C3340avh.IeS e;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
InterfaceC9113ddb interfaceC9113ddb = (InterfaceC9113ddb) obj2;
|
||
|
|
interfaceC9113ddb.a(this.e.c.h.d(this.b));
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.e = this;
|
||
|
|
this.b = ryb;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3340avh3.f != 0) {
|
||
|
|
ieS2.e(c3340avh3.f);
|
||
|
|
}
|
||
|
|
this.c.a = ryb.b;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final void onComplete() {
|
||
|
|
this.c.c.set(false);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final void onError(Throwable th) {
|
||
|
|
this.c.c.set(false);
|
||
|
|
if (this.c.i(th)) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
C3340avh c3340avh = this.c;
|
||
|
|
C3346avn c3346avn = new C3346avn();
|
||
|
|
if (c3340avh.f != 0) {
|
||
|
|
c3346avn.e(c3340avh.f);
|
||
|
|
}
|
||
|
|
C3340avh c3340avh2 = this.c;
|
||
|
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.avr
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
((InterfaceC9113ddb) obj).m();
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3340avh2.f != 0) {
|
||
|
|
ieS.e(c3340avh2.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private static Integer c(String str) {
|
||
|
|
try {
|
||
|
|
return Integer.valueOf(str.replace(",", ""));
|
||
|
|
} catch (Exception unused) {
|
||
|
|
return 0;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
static /* synthetic */ void e(C3340avh c3340avh) {
|
||
|
|
if (c3340avh.f != 0) {
|
||
|
|
c3340avh.f.ar_();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
static /* synthetic */ void h(C3340avh c3340avh) {
|
||
|
|
if (c3340avh.f != 0) {
|
||
|
|
c3340avh.f.ar_();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void c() {
|
||
|
|
tPx tpx = this.a;
|
||
|
|
if (tpx == null || !tpx.c || this.c.get()) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.c.set(true);
|
||
|
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.avl
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
((InterfaceC9113ddb) obj).k();
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (this.f != 0) {
|
||
|
|
ieS.e(this.f);
|
||
|
|
}
|
||
|
|
IeS ieS2 = new IeS(this);
|
||
|
|
this.i.c(new rOI(this.e.e, this.a.a + 1, this.g.d.d(), this.g.d.a() == xKJ.REWARDS_WITHIN_POINTS ? c(this.e.m) : null, this.e.c, this.e.f8200o, this.e.l, this.d.U), false);
|
||
|
|
ZBH zbh = this.i;
|
||
|
|
zbh.d(zbh.i, ieS2);
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void c(boolean z) {
|
||
|
|
if (z && this.f != 0) {
|
||
|
|
this.f.y();
|
||
|
|
}
|
||
|
|
RVV rvv = new RVV(this);
|
||
|
|
this.i.c(new rOI(this.e.e, 0, this.g.d.d(), this.g.d.a() == xKJ.REWARDS_WITHIN_POINTS ? c(this.e.m) : null, this.e.c, this.e.f8200o, this.e.l, this.d.U), false);
|
||
|
|
ZBH zbh = this.i;
|
||
|
|
zbh.d(zbh.i, rvv);
|
||
|
|
}
|
||
|
|
}
|