94 lines
2.6 KiB
Java
94 lines
2.6 KiB
Java
package o;
|
|
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
|
|
/* renamed from: o.fUc, reason: case insensitive filesystem */
|
|
/* loaded from: classes6.dex */
|
|
public final class C13224fUc extends fRY {
|
|
private InterfaceC13153fSa a;
|
|
|
|
public C13224fUc(InterfaceC13153fSa interfaceC13153fSa) {
|
|
this.a = interfaceC13153fSa;
|
|
}
|
|
|
|
@Override // o.fRY
|
|
public final void c(InterfaceC13154fSb interfaceC13154fSb) {
|
|
LWm lWm = new LWm(interfaceC13154fSb);
|
|
interfaceC13154fSb.onSubscribe(lWm);
|
|
try {
|
|
this.a.d(lWm);
|
|
} catch (Throwable th) {
|
|
C13147fSI.c(th);
|
|
if (lWm.d(th)) {
|
|
return;
|
|
}
|
|
C13418fZu.c(th);
|
|
}
|
|
}
|
|
|
|
/* renamed from: o.fUc$LWm */
|
|
/* loaded from: classes6.dex */
|
|
static final class LWm extends AtomicReference<fSJ> implements InterfaceC13118fRX, fSJ {
|
|
private InterfaceC13154fSb c;
|
|
|
|
LWm(InterfaceC13154fSb interfaceC13154fSb) {
|
|
this.c = interfaceC13154fSb;
|
|
}
|
|
|
|
@Override // o.InterfaceC13118fRX
|
|
public final void a() {
|
|
fSJ andSet;
|
|
if (get() == EnumC13192fTf.DISPOSED || (andSet = getAndSet(EnumC13192fTf.DISPOSED)) == EnumC13192fTf.DISPOSED) {
|
|
return;
|
|
}
|
|
try {
|
|
this.c.onComplete();
|
|
} finally {
|
|
if (andSet != null) {
|
|
andSet.dispose();
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC13118fRX
|
|
public final void b(Throwable th) {
|
|
if (d(th)) {
|
|
return;
|
|
}
|
|
C13418fZu.c(th);
|
|
}
|
|
|
|
public final boolean d(Throwable th) {
|
|
fSJ andSet;
|
|
if (th == null) {
|
|
th = fYR.c("onError called with a null Throwable.");
|
|
}
|
|
if (get() == EnumC13192fTf.DISPOSED || (andSet = getAndSet(EnumC13192fTf.DISPOSED)) == EnumC13192fTf.DISPOSED) {
|
|
return false;
|
|
}
|
|
try {
|
|
this.c.onError(th);
|
|
} finally {
|
|
if (andSet != null) {
|
|
andSet.dispose();
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final void dispose() {
|
|
EnumC13192fTf.e(this);
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final boolean isDisposed() {
|
|
return EnumC13192fTf.c(get());
|
|
}
|
|
|
|
@Override // java.util.concurrent.atomic.AtomicReference
|
|
public final String toString() {
|
|
return String.format("%s{%s}", getClass().getSimpleName(), super.toString());
|
|
}
|
|
}
|
|
}
|