454 lines
14 KiB
Java
454 lines
14 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.cWC;
|
||
|
|
import o.wRi;
|
||
|
|
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public final class cWC extends ZI<InterfaceC9010dbe.WNf> {
|
||
|
|
boolean a;
|
||
|
|
private final C0281Da b;
|
||
|
|
private C1233Yp c;
|
||
|
|
public List<? extends C1233Yp> d;
|
||
|
|
public final yGw e;
|
||
|
|
private final C1019Twi g;
|
||
|
|
private String h;
|
||
|
|
private boolean i;
|
||
|
|
private final EF l;
|
||
|
|
|
||
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
||
|
|
@InterfaceC13391fZD
|
||
|
|
public cWC(C0281Da c0281Da, yGw ygw, EF ef, C16903sI c16903sI) {
|
||
|
|
super(c16903sI);
|
||
|
|
C14957gcv.e(c0281Da, "");
|
||
|
|
C14957gcv.e(ygw, "");
|
||
|
|
C14957gcv.e(ef, "");
|
||
|
|
C14957gcv.e(c16903sI, "");
|
||
|
|
this.b = c0281Da;
|
||
|
|
this.e = ygw;
|
||
|
|
this.l = ef;
|
||
|
|
this.g = ygw.a.n();
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.ZI
|
||
|
|
public final void w_() {
|
||
|
|
super.w_();
|
||
|
|
yGw ygw = this.e;
|
||
|
|
if (ygw.h.isDisposed()) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
ygw.h.dispose();
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public static final class RVV extends AbstractC14961gcz implements InterfaceC14894gbR<List<USY>, List<C1233Yp>> {
|
||
|
|
private cWC e;
|
||
|
|
|
||
|
|
@Override // o.InterfaceC14894gbR
|
||
|
|
public final /* synthetic */ List<C1233Yp> invoke(List<USY> list) {
|
||
|
|
YKU yku = new YKU(list);
|
||
|
|
final AnonymousClass4 anonymousClass4 = new AnonymousClass4(this.e);
|
||
|
|
return (List) new YKU(yku.a, new wxK(yku.b, new InterfaceC1244Ytw(anonymousClass4) { // from class: o.cWR
|
||
|
|
private InterfaceC14894gbR a;
|
||
|
|
|
||
|
|
@Override // o.InterfaceC1244Ytw
|
||
|
|
public final Object d(Object obj) {
|
||
|
|
return cWC.RVV.b(this.a, obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.a = anonymousClass4;
|
||
|
|
}
|
||
|
|
})).a(new PRA.Sts(new PRA.AnonymousClass4(), new PRA.AnonymousClass8()));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* renamed from: o.cWC$RVV$4, reason: invalid class name */
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
static final class AnonymousClass4 extends AbstractC14961gcz implements InterfaceC14894gbR<USY, C1233Yp> {
|
||
|
|
private cWC c;
|
||
|
|
|
||
|
|
@Override // o.InterfaceC14894gbR
|
||
|
|
public final /* synthetic */ C1233Yp invoke(USY usy) {
|
||
|
|
C0281Da unused = this.c.b;
|
||
|
|
return C0281Da.a(usy, this.c.e.b.T());
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
||
|
|
AnonymousClass4(cWC cwc) {
|
||
|
|
super(1);
|
||
|
|
this.c = cwc;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ C1233Yp b(InterfaceC14894gbR interfaceC14894gbR, Object obj) {
|
||
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
||
|
|
return (C1233Yp) interfaceC14894gbR.invoke(obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
||
|
|
RVV(cWC cwc) {
|
||
|
|
super(1);
|
||
|
|
this.e = cwc;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void e(String str) {
|
||
|
|
C14957gcv.e(str, "");
|
||
|
|
AbstractC13163fSk<List<USY>> c = this.e.a.c(str);
|
||
|
|
final RVV rvv = new RVV(this);
|
||
|
|
this.e.d(c.map(new fSS(rvv) { // from class: o.cWE
|
||
|
|
private InterfaceC14894gbR e;
|
||
|
|
|
||
|
|
@Override // o.fSS
|
||
|
|
public final Object a(Object obj) {
|
||
|
|
return cWC.d(this.e, obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.e = rvv;
|
||
|
|
}
|
||
|
|
}), new fSQ(this) { // from class: o.cWG
|
||
|
|
private cWC b;
|
||
|
|
|
||
|
|
@Override // o.fSQ
|
||
|
|
public final void c(Object obj) {
|
||
|
|
cWC.d(this.b, (List) obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.b = this;
|
||
|
|
}
|
||
|
|
}, new fSQ(this) { // from class: o.cWI
|
||
|
|
private cWC b;
|
||
|
|
|
||
|
|
@Override // o.fSQ
|
||
|
|
public final void c(Object obj) {
|
||
|
|
cWC.b(this.b, (Throwable) obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.b = this;
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public static final class Sts extends AbstractC14961gcz implements InterfaceC14894gbR<C1233Yp, Boolean> {
|
||
|
|
private cWC d;
|
||
|
|
|
||
|
|
@Override // o.InterfaceC14894gbR
|
||
|
|
public final /* synthetic */ Boolean invoke(C1233Yp c1233Yp) {
|
||
|
|
return Boolean.valueOf(C14957gcv.b((Object) c1233Yp.d, (Object) this.d.g.b));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
||
|
|
Sts(cWC cwc) {
|
||
|
|
super(1);
|
||
|
|
this.d = cwc;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void c(final C1233Yp c1233Yp, final boolean z) {
|
||
|
|
C14957gcv.e(c1233Yp, "");
|
||
|
|
if (TextUtils.isEmpty(this.h)) {
|
||
|
|
this.a = true;
|
||
|
|
this.c = c1233Yp;
|
||
|
|
this.i = z;
|
||
|
|
} else {
|
||
|
|
ZI.IeS ieS = new ZI.IeS(this, c1233Yp, z) { // from class: o.cWD
|
||
|
|
private C1233Yp a;
|
||
|
|
private cWC c;
|
||
|
|
private boolean d;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
cWC.b(this.c, this.a, this.d, (InterfaceC9010dbe.WNf) obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.c = this;
|
||
|
|
this.a = c1233Yp;
|
||
|
|
this.d = z;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (this.f != 0) {
|
||
|
|
ieS.e(this.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public static final class HBt extends AbstractC14961gcz implements InterfaceC14894gbR<C1233Yp, Boolean> {
|
||
|
|
private cWC b;
|
||
|
|
|
||
|
|
@Override // o.InterfaceC14894gbR
|
||
|
|
public final /* synthetic */ Boolean invoke(C1233Yp c1233Yp) {
|
||
|
|
return Boolean.valueOf(C14957gcv.b((Object) c1233Yp.d, (Object) this.b.e.a.n().b));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
||
|
|
public HBt(cWC cwc) {
|
||
|
|
super(1);
|
||
|
|
this.b = cwc;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public final class LWm extends wRi.LWm<List<? extends LEE>> {
|
||
|
|
private cWC e;
|
||
|
|
|
||
|
|
public LWm(cWC cwc) {
|
||
|
|
this.e = cwc;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final /* synthetic */ void onNext(Object obj) {
|
||
|
|
zEQ d;
|
||
|
|
List list = (List) obj;
|
||
|
|
String str = "";
|
||
|
|
C14957gcv.e(list, "");
|
||
|
|
YKU yku = new YKU(list);
|
||
|
|
final Sts sts = Sts.e;
|
||
|
|
YKU yku2 = new YKU(yku.a, new GEP(yku.b, new Jel(sts) { // from class: o.cWM
|
||
|
|
private InterfaceC14894gbR e;
|
||
|
|
|
||
|
|
@Override // o.Jel
|
||
|
|
public final boolean e(Object obj2) {
|
||
|
|
return cWC.LWm.b(this.e, obj2);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.e = sts;
|
||
|
|
}
|
||
|
|
}));
|
||
|
|
if (yku2.b.hasNext()) {
|
||
|
|
d = zEQ.a(yku2.b.next());
|
||
|
|
} else {
|
||
|
|
d = zEQ.d();
|
||
|
|
}
|
||
|
|
cWC cwc = this.e;
|
||
|
|
if (d.d != 0) {
|
||
|
|
T t = d.d;
|
||
|
|
if (t == 0) {
|
||
|
|
throw new NoSuchElementException("No value present");
|
||
|
|
}
|
||
|
|
str = ((LEE) t).c;
|
||
|
|
}
|
||
|
|
cwc.h = str;
|
||
|
|
if (!this.e.a || this.e.c == null) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.e.a = false;
|
||
|
|
final cWC cwc2 = this.e;
|
||
|
|
ZI.IeS ieS = new ZI.IeS(cwc2) { // from class: o.cWN
|
||
|
|
private cWC d;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
cWC.LWm.a(this.d, (InterfaceC9010dbe.WNf) obj2);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.d = cwc2;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (cwc2.f != 0) {
|
||
|
|
ieS.e(cwc2.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final void onError(Throwable th) {
|
||
|
|
C14957gcv.e(th, "");
|
||
|
|
C16903sI unused = this.e.j;
|
||
|
|
guQ.a(C16903sI.b(th), new Object[0]);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
static final class Sts extends AbstractC14961gcz implements InterfaceC14894gbR<LEE, Boolean> {
|
||
|
|
public static final Sts e = new Sts();
|
||
|
|
|
||
|
|
@Override // o.InterfaceC14894gbR
|
||
|
|
public final /* synthetic */ Boolean invoke(LEE lee) {
|
||
|
|
return Boolean.valueOf(gdZ.a("014", lee.c, true));
|
||
|
|
}
|
||
|
|
|
||
|
|
Sts() {
|
||
|
|
super(1);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ void a(cWC cwc, InterfaceC9010dbe.WNf wNf) {
|
||
|
|
C14957gcv.e(cwc, "");
|
||
|
|
EF unused = cwc.l;
|
||
|
|
wNf.a(EF.d(cwc.c, cwc.h), cwc.i);
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ boolean b(InterfaceC14894gbR interfaceC14894gbR, Object obj) {
|
||
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
||
|
|
return ((Boolean) interfaceC14894gbR.invoke(obj)).booleanValue();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ void d(cWC cwc, final List list) {
|
||
|
|
final zEQ d;
|
||
|
|
C14957gcv.e(cwc, "");
|
||
|
|
cwc.d = list;
|
||
|
|
if (cwc.f != 0) {
|
||
|
|
if (cwc.g == null) {
|
||
|
|
ZI.IeS ieS = new ZI.IeS(list) { // from class: o.cWO
|
||
|
|
private List c;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
((InterfaceC9010dbe.WNf) obj).b(this.c);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.c = list;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (cwc.f != 0) {
|
||
|
|
ieS.e(cwc.f);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
YKU yku = new YKU(list);
|
||
|
|
final Sts sts = new Sts(cwc);
|
||
|
|
YKU yku2 = new YKU(yku.a, new GEP(yku.b, new Jel(sts) { // from class: o.cWP
|
||
|
|
private InterfaceC14894gbR b;
|
||
|
|
|
||
|
|
@Override // o.Jel
|
||
|
|
public final boolean e(Object obj) {
|
||
|
|
return cWC.a(this.b, obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.b = sts;
|
||
|
|
}
|
||
|
|
}));
|
||
|
|
if (yku2.b.hasNext()) {
|
||
|
|
d = zEQ.a(yku2.b.next());
|
||
|
|
} else {
|
||
|
|
d = zEQ.d();
|
||
|
|
}
|
||
|
|
if (d.d != 0) {
|
||
|
|
String name = qhK.OWN.name();
|
||
|
|
C1019Twi c1019Twi = cwc.g;
|
||
|
|
if (C14957gcv.b((Object) name, (Object) (c1019Twi != null ? c1019Twi.z : null))) {
|
||
|
|
ZI.IeS ieS2 = new ZI.IeS(d) { // from class: o.cWL
|
||
|
|
private zEQ c;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
cWC.d(this.c, (InterfaceC9010dbe.WNf) obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.c = d;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (cwc.f != 0) {
|
||
|
|
ieS2.e(cwc.f);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
String name2 = qhK.OWN.name();
|
||
|
|
C1019Twi c1019Twi2 = cwc.g;
|
||
|
|
if (C14957gcv.b((Object) name2, (Object) (c1019Twi2 != null ? c1019Twi2.z : null))) {
|
||
|
|
USY usy = new USY();
|
||
|
|
usy.a = cwc.g.b;
|
||
|
|
usy.d = cwc.g.u;
|
||
|
|
C0281Da c0281Da = cwc.b;
|
||
|
|
final C1233Yp a = C0281Da.a(usy, cwc.e.b.T());
|
||
|
|
ZI.IeS ieS3 = new ZI.IeS(a) { // from class: o.cWB
|
||
|
|
private C1233Yp e;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
((InterfaceC9010dbe.WNf) obj).e(this.e);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.e = a;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (cwc.f != 0) {
|
||
|
|
ieS3.e(cwc.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ boolean a(InterfaceC14894gbR interfaceC14894gbR, Object obj) {
|
||
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
||
|
|
return ((Boolean) interfaceC14894gbR.invoke(obj)).booleanValue();
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
public static /* synthetic */ void d(zEQ zeq, InterfaceC9010dbe.WNf wNf) {
|
||
|
|
T t = zeq.d;
|
||
|
|
if (t != 0) {
|
||
|
|
wNf.e((C1233Yp) t);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
throw new NoSuchElementException("No value present");
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ void b(cWC cwc, Throwable th) {
|
||
|
|
C14957gcv.e(cwc, "");
|
||
|
|
if (cwc.i(th)) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.cWK
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
((InterfaceC9010dbe.WNf) obj).b(new ArrayList());
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (cwc.f != 0) {
|
||
|
|
ieS.e(cwc.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ List d(InterfaceC14894gbR interfaceC14894gbR, Object obj) {
|
||
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
||
|
|
return (List) interfaceC14894gbR.invoke(obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ boolean b(InterfaceC14894gbR interfaceC14894gbR, Object obj) {
|
||
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
||
|
|
return ((Boolean) interfaceC14894gbR.invoke(obj)).booleanValue();
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX WARN: Multi-variable type inference failed */
|
||
|
|
public static /* synthetic */ void b(zEQ zeq, InterfaceC9010dbe.WNf wNf) {
|
||
|
|
C14957gcv.e(zeq, "");
|
||
|
|
T t = zeq.d;
|
||
|
|
if (t != 0) {
|
||
|
|
wNf.e((C1233Yp) t);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
throw new NoSuchElementException("No value present");
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ void b(cWC cwc, C1233Yp c1233Yp, boolean z, InterfaceC9010dbe.WNf wNf) {
|
||
|
|
C14957gcv.e(cwc, "");
|
||
|
|
C14957gcv.e(c1233Yp, "");
|
||
|
|
EF ef = cwc.l;
|
||
|
|
wNf.a(EF.d(c1233Yp, cwc.h), z);
|
||
|
|
}
|
||
|
|
}
|