122 lines
3.4 KiB
Java
122 lines
3.4 KiB
Java
package o;
|
|
|
|
import o.ZI;
|
|
import o.cIZ;
|
|
import o.wRi;
|
|
|
|
/* loaded from: classes4.dex */
|
|
public class cIZ extends ZI<InterfaceC8974dav> {
|
|
private final CC a;
|
|
public final Jur b;
|
|
private final CD c;
|
|
private final C16010kTB d;
|
|
public final gHy e;
|
|
private final LVB g;
|
|
private final iEy h;
|
|
private final gHd i;
|
|
private final C0952SdK k;
|
|
private final Oqm m;
|
|
|
|
/* renamed from: o, reason: collision with root package name */
|
|
private final FHl f8606o;
|
|
|
|
@InterfaceC13391fZD
|
|
public cIZ(iEy iey, C16010kTB c16010kTB, C0952SdK c0952SdK, Jur jur, CC cc, FHl fHl, Oqm oqm, gHy ghy, CD cd, gHd ghd, LVB lvb, C16903sI c16903sI) {
|
|
super(c16903sI);
|
|
this.h = iey;
|
|
this.d = c16010kTB;
|
|
this.k = c0952SdK;
|
|
this.b = jur;
|
|
this.f8606o = fHl;
|
|
this.m = oqm;
|
|
this.a = cc;
|
|
this.e = ghy;
|
|
this.c = cd;
|
|
this.i = ghd;
|
|
this.g = lvb;
|
|
}
|
|
|
|
/* loaded from: classes4.dex */
|
|
public class RVV extends wRi.LWm<C16573pSL> {
|
|
private cIZ e;
|
|
|
|
private RVV(cIZ ciz) {
|
|
this.e = ciz;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
final C16573pSL c16573pSL = (C16573pSL) obj;
|
|
cIZ.i(this.e);
|
|
this.e.i.b.c(c16573pSL);
|
|
final ES b = this.e.a.b(this.e.h.c.e(), this.e.k.b.L(), this.e.d.d.d(), this.e.m.c.M(), this.e.b.a.c(), this.e.g.d.g().c.get(0), true, true);
|
|
cIZ ciz = this.e;
|
|
ZI.IeS ieS = new ZI.IeS(this, c16573pSL, b) { // from class: o.cJi
|
|
private ES a;
|
|
private C16573pSL c;
|
|
private cIZ.RVV d;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj2) {
|
|
InterfaceC8974dav interfaceC8974dav = (InterfaceC8974dav) obj2;
|
|
interfaceC8974dav.e(this.d.e.c.a(this.c, this.a));
|
|
}
|
|
|
|
{
|
|
this.d = this;
|
|
this.c = c16573pSL;
|
|
this.a = b;
|
|
}
|
|
};
|
|
if (ciz.f != 0) {
|
|
ieS.e(ciz.f);
|
|
}
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
cIZ.c(this.e, th, new Runnable(this) { // from class: o.cJf
|
|
private cIZ.RVV d;
|
|
|
|
@Override // java.lang.Runnable
|
|
public final void run() {
|
|
cIZ.RVV.c(this.d);
|
|
}
|
|
|
|
{
|
|
this.d = this;
|
|
}
|
|
});
|
|
}
|
|
|
|
public static /* synthetic */ void c(RVV rvv) {
|
|
cIZ ciz = rvv.e;
|
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.cJh
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
((InterfaceC8974dav) obj).b();
|
|
}
|
|
};
|
|
if (ciz.f != 0) {
|
|
ieS.e(ciz.f);
|
|
}
|
|
}
|
|
|
|
public /* synthetic */ RVV(cIZ ciz, byte b) {
|
|
this(ciz);
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void i(cIZ ciz) {
|
|
if (ciz.f != 0) {
|
|
ciz.f.ar_();
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void c(cIZ ciz, Throwable th, Runnable runnable) {
|
|
if (ciz.b(th)) {
|
|
ciz.d(ciz.j.c(th, runnable));
|
|
}
|
|
}
|
|
}
|