139 lines
3.9 KiB
Java
139 lines
3.9 KiB
Java
package o;
|
|
|
|
import java.util.List;
|
|
import o.C4975bkM;
|
|
import o.InterfaceC6663cZf;
|
|
import o.ZI;
|
|
import o.wRi;
|
|
|
|
/* renamed from: o.bkM, reason: case insensitive filesystem */
|
|
/* loaded from: classes4.dex */
|
|
public class C4975bkM extends ZI<InterfaceC6663cZf.HBt> {
|
|
private final C17067tf b;
|
|
private final mvc d;
|
|
|
|
@InterfaceC13391fZD
|
|
public C4975bkM(mvc mvcVar, C17067tf c17067tf, C16903sI c16903sI) {
|
|
super(c16903sI);
|
|
this.d = mvcVar;
|
|
this.b = c17067tf;
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
/* renamed from: o.bkM$HBt */
|
|
/* loaded from: classes4.dex */
|
|
public final class HBt extends wRi.LWm<List<UHI>> {
|
|
private C4975bkM a;
|
|
private boolean e;
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
final List list = (List) obj;
|
|
if (this.a.f != 0) {
|
|
C4975bkM.d(this.a);
|
|
C4975bkM c4975bkM = this.a;
|
|
ZI.IeS ieS = new ZI.IeS(this, list) { // from class: o.bkS
|
|
private C4975bkM.HBt c;
|
|
private List d;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj2) {
|
|
InterfaceC6663cZf.HBt hBt = (InterfaceC6663cZf.HBt) obj2;
|
|
hBt.c((List) C16157lj.c(new Object[]{this.d, new C16164ln(r0.a.b, this.c.e)}, -1846295624, 1846295631, (int) System.currentTimeMillis()));
|
|
}
|
|
|
|
{
|
|
this.c = this;
|
|
this.d = list;
|
|
}
|
|
};
|
|
if (c4975bkM.f != 0) {
|
|
ieS.e(c4975bkM.f);
|
|
}
|
|
}
|
|
}
|
|
|
|
HBt(C4975bkM c4975bkM, boolean z) {
|
|
this.a = c4975bkM;
|
|
this.e = z;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onComplete() {
|
|
C4975bkM.e(this.a);
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(final Throwable th) {
|
|
if (this.a.f == 0 || this.a.i(th)) {
|
|
return;
|
|
}
|
|
C4975bkM.b(this.a);
|
|
C4975bkM c4975bkM = this.a;
|
|
ZI.IeS ieS = new ZI.IeS(this, th) { // from class: o.bkQ
|
|
private C4975bkM.HBt b;
|
|
private Throwable c;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
InterfaceC6663cZf.HBt hBt = (InterfaceC6663cZf.HBt) obj;
|
|
hBt.d(this.b.a.j.e(this.c));
|
|
}
|
|
|
|
{
|
|
this.b = this;
|
|
this.c = th;
|
|
}
|
|
};
|
|
if (c4975bkM.f != 0) {
|
|
ieS.e(c4975bkM.f);
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // o.ZI
|
|
public final void w_() {
|
|
super.w_();
|
|
mvc mvcVar = this.d;
|
|
if (!mvcVar.h.isDisposed()) {
|
|
mvcVar.h.dispose();
|
|
}
|
|
this.d.a.f();
|
|
}
|
|
|
|
static /* synthetic */ void e(C4975bkM c4975bkM) {
|
|
if (c4975bkM.f != 0) {
|
|
c4975bkM.f.aq_();
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void b(C4975bkM c4975bkM) {
|
|
if (c4975bkM.f != 0) {
|
|
c4975bkM.f.aq_();
|
|
}
|
|
}
|
|
|
|
static /* synthetic */ void d(C4975bkM c4975bkM) {
|
|
if (c4975bkM.f != 0) {
|
|
c4975bkM.f.aq_();
|
|
}
|
|
}
|
|
|
|
public final void e(double d, double d2, double d3, double d4, String str, boolean z) {
|
|
if (this.f != 0) {
|
|
this.f.v();
|
|
}
|
|
mvc mvcVar = this.d;
|
|
C5809c d5 = C5809c.d();
|
|
d5.a = d;
|
|
d5.e = d2;
|
|
d5.b = d3;
|
|
d5.h = d4;
|
|
d5.d = str;
|
|
d5.c = z ? 1 : 0;
|
|
mvcVar.c(d5);
|
|
mvc mvcVar2 = this.d;
|
|
mvcVar2.d(mvcVar2.i, new HBt(this, z));
|
|
}
|
|
}
|