149 lines
4.1 KiB
Java
149 lines
4.1 KiB
Java
package o;
|
|
|
|
import java.util.List;
|
|
import o.C2381adY;
|
|
import o.InterfaceC6627cYe;
|
|
import o.ZI;
|
|
import o.wRi;
|
|
|
|
/* renamed from: o.adY, reason: case insensitive filesystem */
|
|
/* loaded from: classes3.dex */
|
|
public class C2381adY extends ZI<InterfaceC6627cYe.tOB> {
|
|
public final mSw b;
|
|
public boolean c;
|
|
private final C16104lK d;
|
|
public List<C0385Fj> e;
|
|
|
|
@InterfaceC13391fZD
|
|
public C2381adY(mSw msw, C16104lK c16104lK, C16903sI c16903sI) {
|
|
super(c16903sI);
|
|
this.b = msw;
|
|
this.d = c16104lK;
|
|
}
|
|
|
|
@Override // o.ZI
|
|
public final void w_() {
|
|
super.w_();
|
|
mSw msw = this.b;
|
|
if (msw.h.isDisposed()) {
|
|
return;
|
|
}
|
|
msw.h.dispose();
|
|
}
|
|
|
|
/* renamed from: o.adY$HBt */
|
|
/* loaded from: classes3.dex */
|
|
public final class HBt extends wRi.LWm<LSn> {
|
|
private C2381adY c;
|
|
|
|
private HBt(C2381adY c2381adY) {
|
|
this.c = c2381adY;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
LSn lSn = (LSn) obj;
|
|
this.c.c = false;
|
|
if (this.c.f != 0) {
|
|
C2381adY c2381adY = this.c;
|
|
C16104lK unused = c2381adY.d;
|
|
c2381adY.e = (List) C16157lj.c(new Object[]{lSn.e, new InterfaceC1244Ytw(this) { // from class: o.aea
|
|
private C2381adY.HBt a;
|
|
|
|
@Override // o.InterfaceC1244Ytw
|
|
public final Object d(Object obj2) {
|
|
return C2381adY.HBt.e(this.a, (KoG) obj2);
|
|
}
|
|
|
|
{
|
|
this.a = this;
|
|
}
|
|
}}, -1846295624, 1846295631, (int) System.currentTimeMillis());
|
|
C2381adY c2381adY2 = this.c;
|
|
ZI.IeS ieS = new ZI.IeS(this) { // from class: o.aeb
|
|
private C2381adY.HBt d;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj2) {
|
|
((InterfaceC6627cYe.tOB) obj2).e(this.d.c.e);
|
|
}
|
|
|
|
{
|
|
this.d = this;
|
|
}
|
|
};
|
|
if (c2381adY2.f != 0) {
|
|
ieS.e(c2381adY2.f);
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onComplete() {
|
|
C2381adY.d(this.c);
|
|
C2381adY.g(this.c);
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(Throwable th) {
|
|
this.c.c = false;
|
|
if (this.c.f == 0 || this.c.i(th)) {
|
|
return;
|
|
}
|
|
C2381adY.j(this.c);
|
|
C2381adY c2381adY = this.c;
|
|
ZI.IeS ieS = new ZI.IeS() { // from class: o.aec
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
((InterfaceC6627cYe.tOB) obj).aM_();
|
|
}
|
|
};
|
|
if (c2381adY.f != 0) {
|
|
ieS.e(c2381adY.f);
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ C0385Fj e(HBt hBt, KoG koG) {
|
|
C16104lK c16104lK = hBt.c.d;
|
|
Object[] objArr = {c16104lK, koG, Boolean.valueOf(hBt.c.b.b.T())};
|
|
System.identityHashCode(c16104lK);
|
|
return (C0385Fj) C16104lK.c(objArr);
|
|
}
|
|
|
|
public /* synthetic */ HBt(C2381adY c2381adY, byte b) {
|
|
this(c2381adY);
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void d(C2381adY c2381adY) {
|
|
if (c2381adY.f != 0) {
|
|
c2381adY.f.aq_();
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void g(C2381adY c2381adY) {
|
|
if (c2381adY.f != 0) {
|
|
c2381adY.f.u();
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void j(C2381adY c2381adY) {
|
|
if (c2381adY.f != 0) {
|
|
c2381adY.f.u();
|
|
}
|
|
}
|
|
|
|
public final void c() {
|
|
if (this.c) {
|
|
return;
|
|
}
|
|
this.c = true;
|
|
if (this.f != 0) {
|
|
this.f.v();
|
|
}
|
|
this.b.g();
|
|
mSw msw = this.b;
|
|
msw.d(msw.i, new HBt(this, (byte) 0));
|
|
}
|
|
}
|