249 lines
7.8 KiB
Java
249 lines
7.8 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.List;
|
||
|
|
import o.C0690Mh;
|
||
|
|
import o.C3241atm;
|
||
|
|
import o.PRA;
|
||
|
|
import o.ZI;
|
||
|
|
import o.wRi;
|
||
|
|
|
||
|
|
/* renamed from: o.atm, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public class C3241atm extends ZI<InterfaceC9042dcJ> {
|
||
|
|
private final C16310nN b;
|
||
|
|
public final C16304nL c;
|
||
|
|
public final ZBH d;
|
||
|
|
private final C16295nG e;
|
||
|
|
|
||
|
|
@InterfaceC13391fZD
|
||
|
|
public C3241atm(C16903sI c16903sI, ZBH zbh, C16310nN c16310nN, C16295nG c16295nG, C16304nL c16304nL) {
|
||
|
|
super(c16903sI);
|
||
|
|
this.d = zbh;
|
||
|
|
this.b = c16310nN;
|
||
|
|
this.e = c16295nG;
|
||
|
|
this.c = c16304nL;
|
||
|
|
}
|
||
|
|
|
||
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
||
|
|
/* renamed from: o.atm$RVV */
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public final class RVV extends wRi.LWm<PNg> {
|
||
|
|
private final C0487Hs a;
|
||
|
|
private C3241atm b;
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final /* synthetic */ void onNext(Object obj) {
|
||
|
|
final PNg pNg = (PNg) obj;
|
||
|
|
C3241atm c3241atm = this.b;
|
||
|
|
ZI.IeS ieS = new ZI.IeS(this, pNg) { // from class: o.atn
|
||
|
|
private PNg c;
|
||
|
|
private C3241atm.RVV e;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
C3241atm.RVV.a(this.e, this.c, (InterfaceC9042dcJ) obj2);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.e = this;
|
||
|
|
this.c = pNg;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3241atm.f != 0) {
|
||
|
|
ieS.e(c3241atm.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
RVV(C3241atm c3241atm, C0487Hs c0487Hs) {
|
||
|
|
this.b = c3241atm;
|
||
|
|
this.a = c0487Hs;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final void onError(final Throwable th) {
|
||
|
|
if (this.b.i(th)) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
C3241atm.b(this.b);
|
||
|
|
C3241atm c3241atm = this.b;
|
||
|
|
ZI.IeS ieS = new ZI.IeS(this, th) { // from class: o.atl
|
||
|
|
private Throwable a;
|
||
|
|
private C3241atm.RVV e;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
InterfaceC9042dcJ interfaceC9042dcJ = (InterfaceC9042dcJ) obj;
|
||
|
|
interfaceC9042dcJ.e(this.e.b.j.d(this.a, C0690Mh.IeS.JUST_DISMISS));
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.e = this;
|
||
|
|
this.a = th;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3241atm.f != 0) {
|
||
|
|
ieS.e(c3241atm.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ void a(RVV rvv, PNg pNg, InterfaceC9042dcJ interfaceC9042dcJ) {
|
||
|
|
List<C0486Hr> list;
|
||
|
|
C3241atm.c(rvv.b);
|
||
|
|
C3241atm c3241atm = rvv.b;
|
||
|
|
if (!C3241atm.c(pNg.b) || pNg.b.get(0).c.booleanValue()) {
|
||
|
|
final C16310nN c16310nN = rvv.b.b;
|
||
|
|
C0487Hs c0487Hs = rvv.a;
|
||
|
|
C0498Hz c0498Hz = new C0498Hz();
|
||
|
|
c0498Hz.g = c0487Hs.g;
|
||
|
|
c0498Hz.b = c0487Hs.b;
|
||
|
|
c0498Hz.d = c0487Hs.d;
|
||
|
|
c0498Hz.c = c0487Hs.c;
|
||
|
|
c0498Hz.a = c0487Hs.a;
|
||
|
|
c0498Hz.e = c0487Hs.e;
|
||
|
|
c0498Hz.h = c0487Hs.h;
|
||
|
|
c0498Hz.i = c0487Hs.i;
|
||
|
|
c0498Hz.j = c0487Hs.j;
|
||
|
|
List<TBH> list2 = pNg.f;
|
||
|
|
if (list2 == null || list2.isEmpty()) {
|
||
|
|
list = null;
|
||
|
|
} else {
|
||
|
|
YKU yku = new YKU(list2);
|
||
|
|
list = (List) new YKU(yku.a, new wxK(yku.b, new InterfaceC1244Ytw(c16310nN) { // from class: o.nQ
|
||
|
|
private C16310nN b;
|
||
|
|
|
||
|
|
@Override // o.InterfaceC1244Ytw
|
||
|
|
public final Object d(Object obj) {
|
||
|
|
return C16310nN.b(this.b, (TBH) obj);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.b = c16310nN;
|
||
|
|
}
|
||
|
|
})).a(new PRA.Sts(new PRA.AnonymousClass4(), new PRA.AnonymousClass8()));
|
||
|
|
}
|
||
|
|
c0498Hz.f8205o = list;
|
||
|
|
c0498Hz.l = pNg.a;
|
||
|
|
c0498Hz.m = pNg.d;
|
||
|
|
interfaceC9042dcJ.b(c0498Hz);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
interfaceC9042dcJ.b(rvv.b.e.c(rvv.a, pNg));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/* renamed from: o.atm$LWm */
|
||
|
|
/* loaded from: classes4.dex */
|
||
|
|
public final class LWm extends wRi.LWm<PNg> {
|
||
|
|
private C3241atm a;
|
||
|
|
private final EnumC16373nni c;
|
||
|
|
private final int e;
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final /* synthetic */ void onNext(Object obj) {
|
||
|
|
final PNg pNg = (PNg) obj;
|
||
|
|
C3241atm c3241atm = this.a;
|
||
|
|
ZI.IeS ieS = new ZI.IeS(this, pNg) { // from class: o.ato
|
||
|
|
private C3241atm.LWm a;
|
||
|
|
private PNg e;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj2) {
|
||
|
|
C3241atm.LWm.a(this.a, this.e, (InterfaceC9042dcJ) obj2);
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.a = this;
|
||
|
|
this.e = pNg;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3241atm.f != 0) {
|
||
|
|
ieS.e(c3241atm.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public LWm(C3241atm c3241atm, int i, EnumC16373nni enumC16373nni) {
|
||
|
|
this.a = c3241atm;
|
||
|
|
this.e = i;
|
||
|
|
this.c = enumC16373nni;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
||
|
|
public final void onError(final Throwable th) {
|
||
|
|
if (this.a.i(th)) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
C3241atm.j(this.a);
|
||
|
|
C3241atm c3241atm = this.a;
|
||
|
|
ZI.IeS ieS = new ZI.IeS(this, th) { // from class: o.atk
|
||
|
|
private Throwable a;
|
||
|
|
private C3241atm.LWm e;
|
||
|
|
|
||
|
|
@Override // o.ZI.IeS
|
||
|
|
public final void e(Object obj) {
|
||
|
|
InterfaceC9042dcJ interfaceC9042dcJ = (InterfaceC9042dcJ) obj;
|
||
|
|
interfaceC9042dcJ.e(this.e.a.j.d(this.a, C0690Mh.IeS.JUST_DISMISS));
|
||
|
|
}
|
||
|
|
|
||
|
|
{
|
||
|
|
this.e = this;
|
||
|
|
this.a = th;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
if (c3241atm.f != 0) {
|
||
|
|
ieS.e(c3241atm.f);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public static /* synthetic */ void a(LWm lWm, PNg pNg, InterfaceC9042dcJ interfaceC9042dcJ) {
|
||
|
|
C3241atm.g(lWm.a);
|
||
|
|
C3241atm c3241atm = lWm.a;
|
||
|
|
if (!C3241atm.c(pNg.f)) {
|
||
|
|
C3241atm c3241atm2 = lWm.a;
|
||
|
|
if (!C3241atm.c(pNg.b)) {
|
||
|
|
C16310nN unused = lWm.a.b;
|
||
|
|
interfaceC9042dcJ.b(C16310nN.b(lWm.e, lWm.c, interfaceC9042dcJ.j(), pNg.a, pNg.d));
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
interfaceC9042dcJ.b(lWm.a.e.b(lWm.e, lWm.c, interfaceC9042dcJ.j(), pNg));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
static /* synthetic */ boolean c(List list) {
|
||
|
|
return (list == null || list.isEmpty()) ? false : true;
|
||
|
|
}
|
||
|
|
|
||
|
|
static /* synthetic */ void b(C3241atm c3241atm) {
|
||
|
|
if (c3241atm.f != 0) {
|
||
|
|
c3241atm.f.ar_();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
static /* synthetic */ void c(C3241atm c3241atm) {
|
||
|
|
if (c3241atm.f != 0) {
|
||
|
|
c3241atm.f.ar_();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
static /* synthetic */ void j(C3241atm c3241atm) {
|
||
|
|
if (c3241atm.f != 0) {
|
||
|
|
c3241atm.f.ar_();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
static /* synthetic */ void g(C3241atm c3241atm) {
|
||
|
|
if (c3241atm.f != 0) {
|
||
|
|
c3241atm.f.ar_();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public final void b(C0487Hs c0487Hs) {
|
||
|
|
if (this.f != 0) {
|
||
|
|
this.f.y();
|
||
|
|
}
|
||
|
|
this.d.c(c0487Hs.a, c0487Hs.g);
|
||
|
|
ZBH zbh = this.d;
|
||
|
|
zbh.d(zbh.i, new RVV(this, c0487Hs));
|
||
|
|
}
|
||
|
|
}
|