112 lines
4.1 KiB
Java
112 lines
4.1 KiB
Java
package o;
|
|
|
|
import java.util.Objects;
|
|
import o.AbstractC15351go;
|
|
import o.AbstractC15351go.HBt;
|
|
|
|
/* renamed from: o.fY, reason: case insensitive filesystem */
|
|
/* loaded from: classes3.dex */
|
|
public class C13353fY<P extends AbstractC15351go.HBt> extends AbstractC15351go {
|
|
private final InterfaceC14894gbR<P, fRY> e;
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
/* JADX WARN: Multi-variable type inference failed */
|
|
public C13353fY(yRw yrw, yRw yrw2, InterfaceC14894gbR<? super P, ? extends fRY> interfaceC14894gbR) {
|
|
super(yrw, yrw2, (byte) 0);
|
|
C14957gcv.e(yrw, "");
|
|
C14957gcv.e(yrw2, "");
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
|
this.e = interfaceC14894gbR;
|
|
}
|
|
|
|
public final void b(InterfaceC13154fSb interfaceC13154fSb, P p, fSC fsc) {
|
|
C14957gcv.e(interfaceC13154fSb, "");
|
|
C14957gcv.e(p, "");
|
|
C14957gcv.e(fsc, "");
|
|
fRY invoke = this.e.invoke(p);
|
|
AbstractC13173fSu abstractC13173fSu = e().d;
|
|
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
|
|
C13239fUr c13239fUr = new C13239fUr(invoke, abstractC13173fSu);
|
|
AbstractC13173fSu abstractC13173fSu2 = a().d;
|
|
Objects.requireNonNull(abstractC13173fSu2, "scheduler is null");
|
|
C13235fUn c13235fUn = new C13235fUn(c13239fUr, abstractC13173fSu2);
|
|
final LWm lWm = new LWm(fsc);
|
|
fSQ<? super fSJ> fsq = new fSQ(lWm) { // from class: o.fX
|
|
private InterfaceC14894gbR d;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
InterfaceC14894gbR interfaceC14894gbR = this.d;
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
|
interfaceC14894gbR.invoke(obj);
|
|
}
|
|
|
|
{
|
|
this.d = lWm;
|
|
}
|
|
};
|
|
fSQ<? super Throwable> c = C13194fTh.c();
|
|
fSP fsp = C13194fTh.c;
|
|
fSP fsp2 = C13194fTh.c;
|
|
c13235fUn.a(fsq, c, fsp, fsp, fsp2, fsp2).e(interfaceC13154fSb);
|
|
}
|
|
|
|
/* renamed from: o.fY$LWm */
|
|
/* loaded from: classes3.dex */
|
|
static final class LWm extends AbstractC14961gcz implements InterfaceC14894gbR<fSJ, C14866gag> {
|
|
private fSC b;
|
|
|
|
@Override // o.InterfaceC14894gbR
|
|
public final /* synthetic */ C14866gag invoke(fSJ fsj) {
|
|
this.b.e(fsj);
|
|
return C14866gag.c;
|
|
}
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
LWm(fSC fsc) {
|
|
super(1);
|
|
this.b = fsc;
|
|
}
|
|
}
|
|
|
|
public final void d(final InterfaceC14890gbN<C14866gag> interfaceC14890gbN, final InterfaceC14894gbR<? super Throwable, C14866gag> interfaceC14894gbR, P p, fSC fsc) {
|
|
C14957gcv.e(interfaceC14890gbN, "");
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
|
C14957gcv.e(p, "");
|
|
C14957gcv.e(fsc, "");
|
|
fRY invoke = this.e.invoke(p);
|
|
AbstractC13173fSu abstractC13173fSu = e().d;
|
|
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
|
|
C13239fUr c13239fUr = new C13239fUr(invoke, abstractC13173fSu);
|
|
AbstractC13173fSu abstractC13173fSu2 = a().d;
|
|
Objects.requireNonNull(abstractC13173fSu2, "scheduler is null");
|
|
fsc.e(new C13235fUn(c13239fUr, abstractC13173fSu2).a(new fSP(interfaceC14890gbN) { // from class: o.gb
|
|
private InterfaceC14890gbN a;
|
|
|
|
@Override // o.fSP
|
|
public final void c() {
|
|
InterfaceC14890gbN interfaceC14890gbN2 = this.a;
|
|
C14957gcv.e(interfaceC14890gbN2, "");
|
|
interfaceC14890gbN2.invoke();
|
|
}
|
|
|
|
{
|
|
this.a = interfaceC14890gbN;
|
|
}
|
|
}, new fSQ(interfaceC14894gbR) { // from class: o.ge
|
|
private InterfaceC14894gbR e;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
InterfaceC14894gbR interfaceC14894gbR2 = this.e;
|
|
C14957gcv.e(interfaceC14894gbR2, "");
|
|
interfaceC14894gbR2.invoke(obj);
|
|
}
|
|
|
|
{
|
|
this.e = interfaceC14894gbR;
|
|
}
|
|
}));
|
|
}
|
|
}
|