162 lines
5.0 KiB
Java
162 lines
5.0 KiB
Java
package o;
|
|
|
|
import o.C15715hv;
|
|
import o.C3076aqg;
|
|
import o.InterfaceC9079dcu;
|
|
import o.ZI;
|
|
import o.wRi;
|
|
import org.threeten.bp.OffsetDateTime;
|
|
|
|
/* renamed from: o.aqg, reason: case insensitive filesystem */
|
|
/* loaded from: classes3.dex */
|
|
public final class C3076aqg extends ZI<InterfaceC9079dcu.IeS> {
|
|
public final xZj a;
|
|
private final YnH b;
|
|
public GR c;
|
|
private final C16398nw d;
|
|
private final C16406nz e;
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
@InterfaceC13391fZD
|
|
public C3076aqg(C16903sI c16903sI, xZj xzj, C16398nw c16398nw, C16406nz c16406nz, YnH ynH) {
|
|
super(c16903sI);
|
|
C14957gcv.e(c16903sI, "");
|
|
C14957gcv.e(xzj, "");
|
|
C14957gcv.e(c16398nw, "");
|
|
C14957gcv.e(c16406nz, "");
|
|
C14957gcv.e(ynH, "");
|
|
this.a = xzj;
|
|
this.d = c16398nw;
|
|
this.e = c16406nz;
|
|
this.b = ynH;
|
|
}
|
|
|
|
/* renamed from: o.aqg$HBt */
|
|
/* loaded from: classes3.dex */
|
|
public final class HBt extends wRi.LWm<C6357cQd> {
|
|
private C3076aqg e;
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final /* synthetic */ void onNext(Object obj) {
|
|
final C6357cQd c6357cQd = (C6357cQd) obj;
|
|
C14957gcv.e(c6357cQd, "");
|
|
final C3076aqg c3076aqg = this.e;
|
|
ZI.IeS ieS = new ZI.IeS(c3076aqg, c6357cQd) { // from class: o.aqn
|
|
private C6357cQd b;
|
|
private C3076aqg e;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj2) {
|
|
C3076aqg.HBt.a(this.e, this.b, (InterfaceC9079dcu.IeS) obj2);
|
|
}
|
|
|
|
{
|
|
this.e = c3076aqg;
|
|
this.b = c6357cQd;
|
|
}
|
|
};
|
|
if (c3076aqg.f != 0) {
|
|
ieS.e(c3076aqg.f);
|
|
}
|
|
}
|
|
|
|
public HBt(C3076aqg c3076aqg) {
|
|
this.e = c3076aqg;
|
|
}
|
|
|
|
@Override // o.wRi.LWm, o.InterfaceC13174fSv
|
|
public final void onError(final Throwable th) {
|
|
C14957gcv.e(th, "");
|
|
final C3076aqg c3076aqg = this.e;
|
|
C14957gcv.e(th, "");
|
|
ZI.IeS ieS = new ZI.IeS(c3076aqg, th) { // from class: o.aqf
|
|
private Throwable c;
|
|
private C3076aqg e;
|
|
|
|
@Override // o.ZI.IeS
|
|
public final void e(Object obj) {
|
|
C3076aqg.b(this.e, this.c, (InterfaceC9079dcu.IeS) obj);
|
|
}
|
|
|
|
{
|
|
this.e = c3076aqg;
|
|
this.c = th;
|
|
}
|
|
};
|
|
if (c3076aqg.f != 0) {
|
|
ieS.e(c3076aqg.f);
|
|
}
|
|
}
|
|
|
|
public static /* synthetic */ void a(C3076aqg c3076aqg, C6357cQd c6357cQd, InterfaceC9079dcu.IeS ieS) {
|
|
C14957gcv.e(c3076aqg, "");
|
|
C14957gcv.e(c6357cQd, "");
|
|
C3076aqg.b(c3076aqg);
|
|
GR gr = c3076aqg.c;
|
|
GL gl = null;
|
|
GR d = gr != null ? c3076aqg.d.d(gr, c6357cQd, c3076aqg.b.b.T()) : null;
|
|
if (d != null) {
|
|
C16406nz c16406nz = c3076aqg.e;
|
|
boolean z = d.i;
|
|
C14957gcv.e(c6357cQd, "");
|
|
String str = (String) C16157lj.c(new Object[]{c16406nz, OffsetDateTime.parse(c6357cQd.e)}, 838289628, -838289623, System.identityHashCode(c16406nz));
|
|
GL gl2 = new GL((byte) 0);
|
|
String string = c16406nz.e.getString(C15715hv.tOB.ref_id_label);
|
|
String str2 = c6357cQd.b;
|
|
StringBuilder sb = new StringBuilder();
|
|
sb.append(string);
|
|
sb.append(" ");
|
|
sb.append(str2);
|
|
gl2.e = sb.toString();
|
|
gl2.a = str;
|
|
gl2.b = c16406nz.b(z);
|
|
gl = gl2;
|
|
}
|
|
ieS.c(gl, d);
|
|
}
|
|
}
|
|
|
|
@Override // o.ZI
|
|
public final void w_() {
|
|
xZj xzj = this.a;
|
|
if (!xzj.h.isDisposed()) {
|
|
xzj.h.dispose();
|
|
}
|
|
YnH ynH = this.b;
|
|
if (!ynH.h.isDisposed()) {
|
|
ynH.h.dispose();
|
|
}
|
|
super.w_();
|
|
}
|
|
|
|
public static /* synthetic */ void b(C3076aqg c3076aqg, Throwable th, final InterfaceC9079dcu.IeS ieS) {
|
|
C14957gcv.e(c3076aqg, "");
|
|
C14957gcv.e(th, "");
|
|
if (c3076aqg.f != 0) {
|
|
c3076aqg.f.ar_();
|
|
}
|
|
if (c3076aqg.b(th, "1035")) {
|
|
ieS.a(c3076aqg.j.e(th));
|
|
} else {
|
|
ieS.e(c3076aqg.j.c(th, new Runnable(ieS) { // from class: o.aqm
|
|
private InterfaceC9079dcu.IeS e;
|
|
|
|
@Override // java.lang.Runnable
|
|
public final void run() {
|
|
this.e.I_();
|
|
}
|
|
|
|
{
|
|
this.e = ieS;
|
|
}
|
|
}));
|
|
}
|
|
}
|
|
|
|
public static final /* synthetic */ void b(C3076aqg c3076aqg) {
|
|
if (c3076aqg.f != 0) {
|
|
c3076aqg.f.ar_();
|
|
}
|
|
}
|
|
}
|