193 lines
5.8 KiB
Java
193 lines
5.8 KiB
Java
package o;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
import o.C1168Xb;
|
|
import o.InterfaceC8929daC;
|
|
import o.PRA;
|
|
import o.wRi;
|
|
|
|
/* renamed from: o.cEq, reason: case insensitive filesystem */
|
|
/* loaded from: classes4.dex */
|
|
public class C5973cEq extends ZI {
|
|
public InterfaceC8929daC.HBt a;
|
|
public boolean b;
|
|
public VJ c;
|
|
public boolean d;
|
|
public double e;
|
|
public BD g;
|
|
public String h;
|
|
public String i;
|
|
public VL k;
|
|
private BL l;
|
|
public VM m;
|
|
public qwQ n;
|
|
|
|
/* renamed from: o, reason: collision with root package name */
|
|
public InterfaceC8929daC.ojQ f8601o;
|
|
|
|
@InterfaceC13391fZD
|
|
public C5973cEq(qwQ qwq, C16903sI c16903sI, BL bl, BD bd) {
|
|
super(c16903sI);
|
|
this.b = false;
|
|
this.n = qwq;
|
|
this.l = bl;
|
|
this.g = bd;
|
|
}
|
|
|
|
@Override // o.ZI
|
|
public final void w_() {
|
|
this.f8601o = null;
|
|
super.w_();
|
|
}
|
|
|
|
public final void d(double d, int i) {
|
|
this.e = d;
|
|
InterfaceC8929daC.HBt hBt = this.a;
|
|
boolean z = false;
|
|
boolean z2 = d > 0.0d;
|
|
boolean z3 = i >= 0;
|
|
if (z2 && z3) {
|
|
z = true;
|
|
}
|
|
hBt.b(z);
|
|
}
|
|
|
|
/* renamed from: o.cEq$RVV */
|
|
/* loaded from: classes4.dex */
|
|
public final class RVV extends wRi.LWm<C8987dbH> {
|
|
private C5973cEq a;
|
|
|
|
private RVV(C5973cEq c5973cEq) {
|
|
this.a = c5973cEq;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
C8987dbH c8987dbH = (C8987dbH) obj;
|
|
C5973cEq c5973cEq = this.a;
|
|
final BD bd = c5973cEq.g;
|
|
VJ vj = new VJ();
|
|
vj.e = VK.d(c8987dbH.d.type);
|
|
vj.d = (List) C16157lj.c(new Object[]{c8987dbH.c, new InterfaceC1244Ytw(bd) { // from class: o.BH
|
|
private BD b;
|
|
|
|
@Override // o.InterfaceC1244Ytw
|
|
public final Object d(Object obj2) {
|
|
return BD.e((Zrr) obj2);
|
|
}
|
|
|
|
{
|
|
this.b = bd;
|
|
}
|
|
}}, -1846295624, 1846295631, (int) System.currentTimeMillis());
|
|
Iterable iterable = c8987dbH.a;
|
|
if (iterable == null) {
|
|
iterable = new ArrayList();
|
|
}
|
|
YKU yku = new YKU(iterable);
|
|
vj.a = (List) new YKU(yku.a, new wxK(yku.b, new InterfaceC1244Ytw(bd) { // from class: o.BF
|
|
private BD a;
|
|
|
|
@Override // o.InterfaceC1244Ytw
|
|
public final Object d(Object obj2) {
|
|
return BD.b((XZr) obj2);
|
|
}
|
|
|
|
{
|
|
this.a = bd;
|
|
}
|
|
})).a(new PRA.Sts(new PRA.AnonymousClass4(), new PRA.AnonymousClass8()));
|
|
vj.c = c8987dbH.b;
|
|
c5973cEq.c = vj;
|
|
if (this.a.f8601o != null) {
|
|
if (!this.a.c.d.isEmpty()) {
|
|
this.a.f8601o.b(this.a.c.d);
|
|
} else {
|
|
this.a.f8601o.e();
|
|
}
|
|
}
|
|
if (this.a.a != null) {
|
|
this.a.a.b(this.a.c.a);
|
|
}
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
if (this.a.f8601o == null || this.a.i(th)) {
|
|
return;
|
|
}
|
|
this.a.f(th);
|
|
}
|
|
|
|
public /* synthetic */ RVV(C5973cEq c5973cEq, byte b) {
|
|
this(c5973cEq);
|
|
}
|
|
}
|
|
|
|
/* renamed from: o.cEq$IeS */
|
|
/* loaded from: classes4.dex */
|
|
public final class IeS extends wRi.LWm<C1006TnQ> {
|
|
private C5973cEq e;
|
|
|
|
private IeS(C5973cEq c5973cEq) {
|
|
this.e = c5973cEq;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
C1189Xo c1189Xo;
|
|
C1006TnQ c1006TnQ = (C1006TnQ) obj;
|
|
if (this.e.a != null && c1006TnQ != null) {
|
|
InterfaceC8929daC.HBt hBt = this.e.a;
|
|
BL bl = this.e.l;
|
|
VL vl = this.e.k;
|
|
double d = this.e.e;
|
|
String str = this.e.h;
|
|
boolean z = this.e.d;
|
|
String str2 = this.e.i;
|
|
if (c1006TnQ == null) {
|
|
c1189Xo = null;
|
|
} else {
|
|
C1189Xo d2 = C1189Xo.h().d(c1006TnQ.c);
|
|
d2.w = c1006TnQ.b == null ? "" : bl.a(c1006TnQ.b);
|
|
d2.U = BL.d(vl.g, vl.c);
|
|
d2.Y = vl.g;
|
|
d2.Z = (String) C6583cXR.c(new Object[]{false, Boolean.valueOf(z), str}, -1092823629, 1092823630, (int) System.currentTimeMillis());
|
|
d2.ab = z ? "MOB" : "CID";
|
|
C1168Xb.LWm lWm = new C1168Xb.LWm();
|
|
lWm.b = BL.c(Double.valueOf(d));
|
|
d2.j = new C1168Xb(lWm, (byte) 0);
|
|
d2.O = str2;
|
|
C1189Xo h = d2.e("rtp.requester").h(BL.c(Double.valueOf(c1006TnQ.a)));
|
|
h.D = c1006TnQ.d;
|
|
c1189Xo = h;
|
|
}
|
|
hBt.c(c1189Xo);
|
|
C5973cEq.o(this.e);
|
|
}
|
|
this.e.b = false;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
if (this.e.a == null || this.e.i(th)) {
|
|
return;
|
|
}
|
|
this.e.f(th);
|
|
this.e.b = false;
|
|
this.e.a.b(true);
|
|
}
|
|
|
|
public /* synthetic */ IeS(C5973cEq c5973cEq, byte b) {
|
|
this(c5973cEq);
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void o(C5973cEq c5973cEq) {
|
|
if (c5973cEq.f != 0) {
|
|
c5973cEq.f.ar_();
|
|
}
|
|
}
|
|
}
|