86 lines
2.2 KiB
Java
86 lines
2.2 KiB
Java
package o;
|
|
|
|
import o.C6796ccF;
|
|
import o.InterfaceC8954dab;
|
|
import o.ZI;
|
|
import o.wRi;
|
|
|
|
/* renamed from: o.ccF, reason: case insensitive filesystem */
|
|
/* loaded from: classes4.dex */
|
|
public class C6796ccF extends ZI<InterfaceC8954dab.HBt> {
|
|
public String a;
|
|
public final aBQ b;
|
|
private final C17659yi c;
|
|
public String d;
|
|
private SL e;
|
|
|
|
@InterfaceC13391fZD
|
|
public C6796ccF(C16903sI c16903sI, C17659yi c17659yi, aBQ abq) {
|
|
super(c16903sI);
|
|
this.c = c17659yi;
|
|
this.b = abq;
|
|
}
|
|
|
|
/* renamed from: o.ccF$HBt */
|
|
/* loaded from: classes4.dex */
|
|
public class HBt extends wRi.LWm<C16359nhm> {
|
|
private C6796ccF a;
|
|
|
|
public HBt(C6796ccF c6796ccF) {
|
|
this.a = c6796ccF;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
C16359nhm c16359nhm = (C16359nhm) obj;
|
|
C6796ccF.c(this.a);
|
|
if (c16359nhm != null) {
|
|
C6796ccF c6796ccF = this.a;
|
|
c6796ccF.e = c6796ccF.c.e(c16359nhm);
|
|
C6796ccF c6796ccF2 = this.a;
|
|
ZI.IeS ieS = new ZI.IeS(this) { // from class: o.ccL
|
|
private C6796ccF.HBt e;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj2) {
|
|
((InterfaceC8954dab.HBt) obj2).b(this.e.a.e);
|
|
}
|
|
|
|
{
|
|
this.e = this;
|
|
}
|
|
};
|
|
if (c6796ccF2.f != 0) {
|
|
ieS.e(c6796ccF2.f);
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
C6796ccF.b(this.a);
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void b(C6796ccF c6796ccF) {
|
|
if (c6796ccF.f != 0) {
|
|
c6796ccF.f.ar_();
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void c(C6796ccF c6796ccF) {
|
|
if (c6796ccF.f != 0) {
|
|
c6796ccF.f.ar_();
|
|
}
|
|
}
|
|
|
|
@Override // o.ZI
|
|
public final void w_() {
|
|
aBQ abq = this.b;
|
|
if (!abq.h.isDisposed()) {
|
|
abq.h.dispose();
|
|
}
|
|
super.w_();
|
|
}
|
|
}
|