367 lines
11 KiB
Java
367 lines
11 KiB
Java
package o;
|
|
|
|
import android.text.TextUtils;
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
import java.util.NoSuchElementException;
|
|
import o.InterfaceC9010dbe;
|
|
import o.PRA;
|
|
import o.ZI;
|
|
import o.cWT;
|
|
import o.wRi;
|
|
|
|
/* loaded from: classes4.dex */
|
|
public class cWT extends ZI<InterfaceC9010dbe.WNf> {
|
|
boolean a;
|
|
public AbstractC1237Yr b;
|
|
public List<C1233Yp> c;
|
|
private C1233Yp d;
|
|
public final yGw e;
|
|
private String g;
|
|
private final C0281Da h;
|
|
private C1019Twi i;
|
|
private final EF m;
|
|
|
|
/* renamed from: o, reason: collision with root package name */
|
|
private boolean f8629o;
|
|
|
|
@InterfaceC13391fZD
|
|
public cWT(C0281Da c0281Da, yGw ygw, EF ef, C16903sI c16903sI) {
|
|
super(c16903sI);
|
|
this.g = "000";
|
|
this.h = c0281Da;
|
|
this.e = ygw;
|
|
this.m = ef;
|
|
this.i = ygw.a.n();
|
|
}
|
|
|
|
@Override // o.ZI
|
|
public final void w_() {
|
|
super.w_();
|
|
yGw ygw = this.e;
|
|
if (ygw.h.isDisposed()) {
|
|
return;
|
|
}
|
|
ygw.h.dispose();
|
|
}
|
|
|
|
public final void b(String str) {
|
|
this.e.d(this.e.a.c(str).map(new fSS(this) { // from class: o.cWX
|
|
private cWT b;
|
|
|
|
@Override // o.fSS
|
|
public final Object a(Object obj) {
|
|
return cWT.a(this.b, (List) obj);
|
|
}
|
|
|
|
{
|
|
this.b = this;
|
|
}
|
|
}), new fSQ(this) { // from class: o.cWV
|
|
private cWT e;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
cWT.d(this.e, (List) obj);
|
|
}
|
|
|
|
{
|
|
this.e = this;
|
|
}
|
|
}, new fSQ(this) { // from class: o.cWU
|
|
private cWT d;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
cWT.c(this.d, (Throwable) obj);
|
|
}
|
|
|
|
{
|
|
this.d = this;
|
|
}
|
|
});
|
|
}
|
|
|
|
public final void e(final C1233Yp c1233Yp, final boolean z) {
|
|
if (TextUtils.isEmpty(this.g)) {
|
|
this.a = true;
|
|
this.d = c1233Yp;
|
|
this.f8629o = z;
|
|
} else {
|
|
if (this.b != null) {
|
|
ZI.IeS ieS = new ZI.IeS(this, c1233Yp, z) { // from class: o.cWQ
|
|
private boolean a;
|
|
private C1233Yp b;
|
|
private cWT c;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
cWT.e(this.c, this.b, this.a, (InterfaceC9010dbe.WNf) obj);
|
|
}
|
|
|
|
{
|
|
this.c = this;
|
|
this.b = c1233Yp;
|
|
this.a = z;
|
|
}
|
|
};
|
|
if (this.f != 0) {
|
|
ieS.e(this.f);
|
|
return;
|
|
}
|
|
return;
|
|
}
|
|
ZI.IeS ieS2 = new ZI.IeS(this, c1233Yp, z) { // from class: o.cXa
|
|
private C1233Yp b;
|
|
private cWT c;
|
|
private boolean d;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
cWT.c(this.c, this.b, this.d, (InterfaceC9010dbe.WNf) obj);
|
|
}
|
|
|
|
{
|
|
this.c = this;
|
|
this.b = c1233Yp;
|
|
this.d = z;
|
|
}
|
|
};
|
|
if (this.f != 0) {
|
|
ieS2.e(this.f);
|
|
}
|
|
}
|
|
}
|
|
|
|
/* loaded from: classes4.dex */
|
|
public final class Sts extends wRi.LWm<List<LEE>> {
|
|
private cWT e;
|
|
|
|
private Sts(cWT cwt) {
|
|
this.e = cwt;
|
|
}
|
|
|
|
/* JADX WARN: Multi-variable type inference failed */
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
zEQ d;
|
|
String str;
|
|
YKU yku = new YKU((List) obj);
|
|
YKU yku2 = new YKU(yku.a, new GEP(yku.b, new Jel() { // from class: o.cXl
|
|
@Override // o.Jel
|
|
public final boolean e(Object obj2) {
|
|
boolean equalsIgnoreCase;
|
|
equalsIgnoreCase = "000".equalsIgnoreCase(((LEE) obj2).c);
|
|
return equalsIgnoreCase;
|
|
}
|
|
}));
|
|
if (yku2.b.hasNext()) {
|
|
d = zEQ.a(yku2.b.next());
|
|
} else {
|
|
d = zEQ.d();
|
|
}
|
|
cWT cwt = this.e;
|
|
if (d.d == 0) {
|
|
str = "";
|
|
} else {
|
|
T t = d.d;
|
|
if (t == 0) {
|
|
throw new NoSuchElementException("No value present");
|
|
}
|
|
str = ((LEE) t).c;
|
|
}
|
|
cwt.g = str;
|
|
if (!this.e.a || this.e.d == null) {
|
|
return;
|
|
}
|
|
this.e.a = false;
|
|
cWT cwt2 = this.e;
|
|
ZI.IeS ieS = new ZI.IeS(this) { // from class: o.cXj
|
|
private cWT.Sts d;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj2) {
|
|
cWT.Sts.e(this.d, (InterfaceC9010dbe.WNf) obj2);
|
|
}
|
|
|
|
{
|
|
this.d = this;
|
|
}
|
|
};
|
|
if (cwt2.f != 0) {
|
|
ieS.e(cwt2.f);
|
|
}
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
C16903sI unused = this.e.j;
|
|
guQ.a(C16903sI.b(th), new Object[0]);
|
|
}
|
|
|
|
public static /* synthetic */ void e(Sts sts, InterfaceC9010dbe.WNf wNf) {
|
|
EF unused = sts.e.m;
|
|
wNf.a(EF.d(sts.e.d, sts.e.g), sts.e.f8629o);
|
|
}
|
|
|
|
public /* synthetic */ Sts(cWT cwt, byte b) {
|
|
this(cwt);
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ void c(cWT cwt, C1233Yp c1233Yp, boolean z, InterfaceC9010dbe.WNf wNf) {
|
|
EF ef = cwt.m;
|
|
wNf.a(EF.d(c1233Yp, cwt.g), z);
|
|
}
|
|
|
|
public static /* synthetic */ C1233Yp a(cWT cwt, USY usy) {
|
|
C0281Da c0281Da = cwt.h;
|
|
return C0281Da.a(usy, cwt.e.b.T());
|
|
}
|
|
|
|
public static /* synthetic */ void d(final cWT cwt, final List list) {
|
|
final zEQ d;
|
|
cwt.c = list;
|
|
if (cwt.f != 0) {
|
|
if (cwt.i == null) {
|
|
ZI.IeS ieS = new ZI.IeS(list) { // from class: o.cXe
|
|
private List a;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
((InterfaceC9010dbe.WNf) obj).b(this.a);
|
|
}
|
|
|
|
{
|
|
this.a = list;
|
|
}
|
|
};
|
|
if (cwt.f != 0) {
|
|
ieS.e(cwt.f);
|
|
return;
|
|
}
|
|
return;
|
|
}
|
|
YKU yku = new YKU(list);
|
|
YKU yku2 = new YKU(yku.a, new GEP(yku.b, new Jel(cwt) { // from class: o.cXf
|
|
private cWT e;
|
|
|
|
@Override // o.Jel
|
|
public final boolean e(Object obj) {
|
|
boolean equals;
|
|
equals = ((C1233Yp) obj).d.equals(this.e.i.b);
|
|
return equals;
|
|
}
|
|
|
|
{
|
|
this.e = cwt;
|
|
}
|
|
}));
|
|
if (yku2.b.hasNext()) {
|
|
d = zEQ.a(yku2.b.next());
|
|
} else {
|
|
d = zEQ.d();
|
|
}
|
|
if (d.d != 0 && qhK.OWN.name().equals(cwt.i.z)) {
|
|
ZI.IeS ieS2 = new ZI.IeS(d) { // from class: o.cXc
|
|
private zEQ c;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
cWT.e(this.c, (InterfaceC9010dbe.WNf) obj);
|
|
}
|
|
|
|
{
|
|
this.c = d;
|
|
}
|
|
};
|
|
if (cwt.f != 0) {
|
|
ieS2.e(cwt.f);
|
|
return;
|
|
}
|
|
return;
|
|
}
|
|
if (qhK.OWN.name().equals(cwt.i.z)) {
|
|
USY usy = new USY();
|
|
usy.a = cwt.i.b;
|
|
usy.d = cwt.i.u;
|
|
C0281Da c0281Da = cwt.h;
|
|
final C1233Yp a = C0281Da.a(usy, cwt.e.b.T());
|
|
ZI.IeS ieS3 = new ZI.IeS(a) { // from class: o.cXg
|
|
private C1233Yp e;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
((InterfaceC9010dbe.WNf) obj).e(this.e);
|
|
}
|
|
|
|
{
|
|
this.e = a;
|
|
}
|
|
};
|
|
if (cwt.f != 0) {
|
|
ieS3.e(cwt.f);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ List a(final cWT cwt, List list) {
|
|
YKU yku = new YKU(list);
|
|
return (List) new YKU(yku.a, new wxK(yku.b, new InterfaceC1244Ytw(cwt) { // from class: o.cWS
|
|
private cWT b;
|
|
|
|
@Override // o.InterfaceC1244Ytw
|
|
public final Object d(Object obj) {
|
|
return cWT.a(this.b, (USY) obj);
|
|
}
|
|
|
|
{
|
|
this.b = cwt;
|
|
}
|
|
})).a(new PRA.Sts(new PRA.AnonymousClass4(), new PRA.AnonymousClass8()));
|
|
}
|
|
|
|
public static /* synthetic */ void e(cWT cwt, C1233Yp c1233Yp, boolean z, InterfaceC9010dbe.WNf wNf) {
|
|
EF ef = cwt.m;
|
|
wNf.a(EF.e(cwt.b, c1233Yp), z);
|
|
}
|
|
|
|
public static /* synthetic */ void c(cWT cwt, Throwable th) {
|
|
if (cwt.i(th)) {
|
|
return;
|
|
}
|
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.cXd
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
((InterfaceC9010dbe.WNf) obj).b(new ArrayList());
|
|
}
|
|
};
|
|
if (cwt.f != 0) {
|
|
ieS.e(cwt.f);
|
|
}
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
/* JADX WARN: Multi-variable type inference failed */
|
|
public static /* synthetic */ void e(zEQ zeq, InterfaceC9010dbe.WNf wNf) {
|
|
T t = zeq.d;
|
|
if (t != 0) {
|
|
wNf.e((C1233Yp) t);
|
|
return;
|
|
}
|
|
throw new NoSuchElementException("No value present");
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
/* JADX WARN: Multi-variable type inference failed */
|
|
public static /* synthetic */ void b(zEQ zeq, InterfaceC9010dbe.WNf wNf) {
|
|
T t = zeq.d;
|
|
if (t != 0) {
|
|
wNf.e((C1233Yp) t);
|
|
return;
|
|
}
|
|
throw new NoSuchElementException("No value present");
|
|
}
|
|
}
|