368 lines
10 KiB
Java
368 lines
10 KiB
Java
package o;
|
|
|
|
import java.util.List;
|
|
import o.ZI;
|
|
import o.cDA;
|
|
import o.wRi;
|
|
|
|
/* loaded from: classes4.dex */
|
|
public final class cDA extends ZI<InterfaceC9570dmI> {
|
|
private final QAJ a;
|
|
private final C0232By b;
|
|
private final NKs c;
|
|
public UO d;
|
|
public final BvD e;
|
|
private final C0169Aq g;
|
|
private final EhV i;
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
@InterfaceC13391fZD
|
|
public cDA(BvD bvD, QAJ qaj, EhV ehV, NKs nKs, C0169Aq c0169Aq, C0232By c0232By, C16903sI c16903sI) {
|
|
super(c16903sI);
|
|
C14957gcv.e(bvD, "");
|
|
C14957gcv.e(qaj, "");
|
|
C14957gcv.e(ehV, "");
|
|
C14957gcv.e(nKs, "");
|
|
C14957gcv.e(c0169Aq, "");
|
|
C14957gcv.e(c0232By, "");
|
|
C14957gcv.e(c16903sI, "");
|
|
this.e = bvD;
|
|
this.a = qaj;
|
|
this.i = ehV;
|
|
this.c = nKs;
|
|
this.g = c0169Aq;
|
|
this.b = c0232By;
|
|
}
|
|
|
|
/* loaded from: classes4.dex */
|
|
public static final class Sts extends wRi.LWm<C2414aeE> {
|
|
private cDA b;
|
|
|
|
Sts(cDA cda) {
|
|
this.b = cda;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
C2414aeE c2414aeE = (C2414aeE) obj;
|
|
C14957gcv.e(c2414aeE, "");
|
|
cDA cda = this.b;
|
|
ZI.IeS ieS = new ZI.IeS(c2414aeE) { // from class: o.cDS
|
|
private C2414aeE e;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj2) {
|
|
cDA.Sts.d(this.e, (InterfaceC9570dmI) obj2);
|
|
}
|
|
|
|
{
|
|
this.e = c2414aeE;
|
|
}
|
|
};
|
|
if (cda.f != 0) {
|
|
ieS.e(cda.f);
|
|
}
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
C14957gcv.e(th, "");
|
|
cDA cda = this.b;
|
|
cDA.b(cda, th, new Runnable(cda) { // from class: o.cDR
|
|
private cDA c;
|
|
|
|
@Override // java.lang.Runnable
|
|
public final void run() {
|
|
cDA.Sts.c(this.c);
|
|
}
|
|
|
|
{
|
|
this.c = cda;
|
|
}
|
|
});
|
|
}
|
|
|
|
public static /* synthetic */ void c(cDA cda) {
|
|
C14957gcv.e(cda, "");
|
|
cDN cdn = new cDN();
|
|
if (cda.f != 0) {
|
|
cdn.e(cda.f);
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ void d(C2414aeE c2414aeE, InterfaceC9570dmI interfaceC9570dmI) {
|
|
C14957gcv.e(c2414aeE, "");
|
|
List<String> list = c2414aeE.d;
|
|
C14957gcv.c(list, "");
|
|
interfaceC9570dmI.e(list);
|
|
interfaceC9570dmI.ar_();
|
|
}
|
|
}
|
|
|
|
public final void c(String str, VH vh) {
|
|
UH uh;
|
|
C14957gcv.e(str, "");
|
|
C14957gcv.e(vh, "");
|
|
String str2 = null;
|
|
if (!this.c.b()) {
|
|
ZI.IeS ieS = new ZI.IeS((VH) C0232By.d(new Object[]{str, null, vh}, -588778539, 588778541, (int) System.currentTimeMillis())) { // from class: o.cDD
|
|
private VH b;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
cDA.e(this.b, (InterfaceC9570dmI) obj);
|
|
}
|
|
|
|
{
|
|
this.b = r1;
|
|
}
|
|
};
|
|
if (this.f != 0) {
|
|
ieS.e(this.f);
|
|
return;
|
|
}
|
|
return;
|
|
}
|
|
if (this.f != 0) {
|
|
this.f.y();
|
|
}
|
|
UO uo = this.d;
|
|
if (uo != null && (uh = uo.e) != null) {
|
|
str2 = uh.d;
|
|
}
|
|
C10241dz c10241dz = new C10241dz(new C8060dA(null, null, null, null, null, null, null, null, null, null, null, str2, 8191));
|
|
EhV ehV = this.i;
|
|
C14957gcv.e(c10241dz, "");
|
|
AbstractC13163fSk<LFv> e = ehV.c.e(c10241dz);
|
|
C14957gcv.c(e, "");
|
|
ehV.d(e, new fSQ(this, str, vh) { // from class: o.cDF
|
|
private cDA a;
|
|
private VH c;
|
|
private String e;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
cDA.c(this.a, this.e, this.c);
|
|
}
|
|
|
|
{
|
|
this.a = this;
|
|
this.e = str;
|
|
this.c = vh;
|
|
}
|
|
}, new fSQ(this) { // from class: o.cDG
|
|
private cDA e;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
cDA.c(this.e, (Throwable) obj);
|
|
}
|
|
|
|
{
|
|
this.e = this;
|
|
}
|
|
});
|
|
}
|
|
|
|
@Override // o.ZI
|
|
public final void w_() {
|
|
QAJ qaj = this.a;
|
|
if (!qaj.h.isDisposed()) {
|
|
qaj.h.dispose();
|
|
}
|
|
BvD bvD = this.e;
|
|
if (!bvD.h.isDisposed()) {
|
|
bvD.h.dispose();
|
|
}
|
|
EhV ehV = this.i;
|
|
if (!ehV.h.isDisposed()) {
|
|
ehV.h.dispose();
|
|
}
|
|
super.w_();
|
|
}
|
|
|
|
public static /* synthetic */ void d(cDA cda) {
|
|
C14957gcv.e(cda, "");
|
|
cDN cdn = new cDN();
|
|
if (cda.f != 0) {
|
|
cdn.e(cda.f);
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ void a(cDA cda, String str, InterfaceC9570dmI interfaceC9570dmI) {
|
|
C14957gcv.e(cda, "");
|
|
if (cda.c.b()) {
|
|
interfaceC9570dmI.b(str);
|
|
} else {
|
|
interfaceC9570dmI.b();
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ void c(cDA cda, LFv lFv) {
|
|
UH uh;
|
|
C0169Aq c0169Aq = cda.g;
|
|
C14957gcv.e(lFv, "");
|
|
UO uo = new UO(C0169Aq.e(lFv.b));
|
|
cda.d = uo;
|
|
cda.a(uo);
|
|
UO uo2 = cda.d;
|
|
ZI.IeS ieS = new ZI.IeS(cda, (uo2 == null || (uh = uo2.e) == null) ? null : uh.d) { // from class: o.cDO
|
|
private cDA b;
|
|
private String d;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
cDA.a(this.b, this.d, (InterfaceC9570dmI) obj);
|
|
}
|
|
|
|
{
|
|
this.b = cda;
|
|
this.d = r2;
|
|
}
|
|
};
|
|
if (cda.f != 0) {
|
|
ieS.e(cda.f);
|
|
}
|
|
QAJ qaj = cda.a;
|
|
C5913cD c5913cD = new C5913cD();
|
|
c5913cD.d = "all";
|
|
qaj.b(c5913cD);
|
|
QAJ qaj2 = cda.a;
|
|
qaj2.d(qaj2.i, new Sts(cda));
|
|
cDQ cdq = new cDQ(cda.e(cda.d));
|
|
if (cda.f != 0) {
|
|
cdq.e(cda.f);
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ void a(cDA cda, InterfaceC9570dmI interfaceC9570dmI) {
|
|
C14957gcv.e(cda, "");
|
|
interfaceC9570dmI.a(cda.d);
|
|
}
|
|
|
|
public static /* synthetic */ void b(String str, InterfaceC9570dmI interfaceC9570dmI) {
|
|
if (str == null || !(!gdZ.d((CharSequence) str))) {
|
|
return;
|
|
}
|
|
interfaceC9570dmI.c(str);
|
|
}
|
|
|
|
public static /* synthetic */ void c(cDA cda, String str, VH vh) {
|
|
C14957gcv.e(cda, "");
|
|
C14957gcv.e(str, "");
|
|
C14957gcv.e(vh, "");
|
|
if (cda.f != 0) {
|
|
cda.f.ar_();
|
|
}
|
|
ZI.IeS ieS = new ZI.IeS(cda, str, vh) { // from class: o.cDK
|
|
private String a;
|
|
private VH c;
|
|
private cDA e;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
cDA.d(this.e, this.a, this.c, (InterfaceC9570dmI) obj);
|
|
}
|
|
|
|
{
|
|
this.e = cda;
|
|
this.a = str;
|
|
this.c = vh;
|
|
}
|
|
};
|
|
if (cda.f != 0) {
|
|
ieS.e(cda.f);
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ void e(VH vh, InterfaceC9570dmI interfaceC9570dmI) {
|
|
C14957gcv.e(vh, "");
|
|
interfaceC9570dmI.d(vh);
|
|
}
|
|
|
|
public static /* synthetic */ void b(cDA cda, Throwable th) {
|
|
if (cda.c(th, true)) {
|
|
return;
|
|
}
|
|
Runnable runnable = new Runnable(cda) { // from class: o.cDM
|
|
private cDA a;
|
|
|
|
@Override // java.lang.Runnable
|
|
public final void run() {
|
|
cDA.d(this.a);
|
|
}
|
|
|
|
{
|
|
this.a = cda;
|
|
}
|
|
};
|
|
if (cda.b(th)) {
|
|
cda.d(cda.j.c(th, runnable));
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ void c(cDA cda, Throwable th) {
|
|
C14957gcv.e(cda, "");
|
|
if (cda.b(th)) {
|
|
cda.d(cda.j.e(th));
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ void d(cDA cda, String str, VH vh, InterfaceC9570dmI interfaceC9570dmI) {
|
|
UH uh;
|
|
C14957gcv.e(cda, "");
|
|
C14957gcv.e(str, "");
|
|
C14957gcv.e(vh, "");
|
|
C0232By c0232By = cda.b;
|
|
UO uo = cda.d;
|
|
interfaceC9570dmI.d((VH) C0232By.d(new Object[]{str, (uo == null || (uh = uo.e) == null) ? null : uh.d, vh}, -588778539, 588778541, (int) System.currentTimeMillis()));
|
|
}
|
|
|
|
public static final /* synthetic */ void b(cDA cda, Throwable th, Runnable runnable) {
|
|
if (cda.b(th)) {
|
|
cda.d(cda.j.c(th, runnable));
|
|
}
|
|
}
|
|
|
|
public final boolean e(UO uo) {
|
|
UH uh;
|
|
String str;
|
|
if (uo == null || (uh = uo.e) == null) {
|
|
return false;
|
|
}
|
|
if (this.c.b()) {
|
|
if (uh.e == null || !(!gdZ.d((CharSequence) r1)) || (str = uh.d) == null) {
|
|
return false;
|
|
}
|
|
String str2 = str;
|
|
if (!(!(str2 == null || gdZ.d((CharSequence) str2)))) {
|
|
return false;
|
|
}
|
|
} else {
|
|
if (uh.e == null || !(!gdZ.d((CharSequence) r4))) {
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public final void a(UO uo) {
|
|
UH uh;
|
|
ZI.IeS ieS = new ZI.IeS((uo == null || (uh = uo.e) == null) ? null : uh.e) { // from class: o.cDJ
|
|
private String b;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
cDA.b(this.b, (InterfaceC9570dmI) obj);
|
|
}
|
|
|
|
{
|
|
this.b = r1;
|
|
}
|
|
};
|
|
if (this.f != 0) {
|
|
ieS.e(this.f);
|
|
}
|
|
}
|
|
}
|