119 lines
3.3 KiB
Java
119 lines
3.3 KiB
Java
package o;
|
|
|
|
import io.reactivex.rxjava3.exceptions.CompositeException;
|
|
|
|
/* renamed from: o.fUm, reason: case insensitive filesystem */
|
|
/* loaded from: classes6.dex */
|
|
public final class C13234fUm extends fRY {
|
|
final fSP a;
|
|
final fSP b;
|
|
final fSQ<? super Throwable> c;
|
|
final fSQ<? super fSJ> d;
|
|
final fSP e;
|
|
final fSP i;
|
|
private fRZ j;
|
|
|
|
public C13234fUm(fRZ frz, fSQ<? super fSJ> fsq, fSQ<? super Throwable> fsq2, fSP fsp, fSP fsp2, fSP fsp3, fSP fsp4) {
|
|
this.j = frz;
|
|
this.d = fsq;
|
|
this.c = fsq2;
|
|
this.e = fsp;
|
|
this.i = fsp2;
|
|
this.a = fsp3;
|
|
this.b = fsp4;
|
|
}
|
|
|
|
@Override // o.fRY
|
|
public final void c(InterfaceC13154fSb interfaceC13154fSb) {
|
|
this.j.e(new Sts(this, interfaceC13154fSb));
|
|
}
|
|
|
|
/* renamed from: o.fUm$Sts */
|
|
/* loaded from: classes6.dex */
|
|
final class Sts implements InterfaceC13154fSb, fSJ {
|
|
private C13234fUm b;
|
|
private InterfaceC13154fSb c;
|
|
private fSJ d;
|
|
|
|
Sts(C13234fUm c13234fUm, InterfaceC13154fSb interfaceC13154fSb) {
|
|
this.b = c13234fUm;
|
|
this.c = interfaceC13154fSb;
|
|
}
|
|
|
|
@Override // o.InterfaceC13154fSb
|
|
public final void onSubscribe(fSJ fsj) {
|
|
try {
|
|
this.b.d.c(fsj);
|
|
if (EnumC13192fTf.d(this.d, fsj)) {
|
|
this.d = fsj;
|
|
this.c.onSubscribe(this);
|
|
}
|
|
} catch (Throwable th) {
|
|
C13147fSI.c(th);
|
|
fsj.dispose();
|
|
this.d = EnumC13192fTf.DISPOSED;
|
|
EnumC13195fTi.c(th, this.c);
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC13154fSb
|
|
public final void onError(Throwable th) {
|
|
if (this.d == EnumC13192fTf.DISPOSED) {
|
|
C13418fZu.c(th);
|
|
return;
|
|
}
|
|
try {
|
|
this.b.c.c(th);
|
|
this.b.i.c();
|
|
} catch (Throwable th2) {
|
|
C13147fSI.c(th2);
|
|
th = new CompositeException(th, th2);
|
|
}
|
|
this.c.onError(th);
|
|
try {
|
|
this.b.a.c();
|
|
} catch (Throwable th3) {
|
|
C13147fSI.c(th3);
|
|
C13418fZu.c(th3);
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC13154fSb
|
|
public final void onComplete() {
|
|
if (this.d == EnumC13192fTf.DISPOSED) {
|
|
return;
|
|
}
|
|
try {
|
|
this.b.e.c();
|
|
this.b.i.c();
|
|
this.c.onComplete();
|
|
try {
|
|
this.b.a.c();
|
|
} catch (Throwable th) {
|
|
C13147fSI.c(th);
|
|
C13418fZu.c(th);
|
|
}
|
|
} catch (Throwable th2) {
|
|
C13147fSI.c(th2);
|
|
this.c.onError(th2);
|
|
}
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final void dispose() {
|
|
try {
|
|
this.b.b.c();
|
|
} catch (Throwable th) {
|
|
C13147fSI.c(th);
|
|
C13418fZu.c(th);
|
|
}
|
|
this.d.dispose();
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final boolean isDisposed() {
|
|
return this.d.isDisposed();
|
|
}
|
|
}
|
|
}
|