117 lines
3.2 KiB
Java
117 lines
3.2 KiB
Java
package o;
|
|
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
|
|
/* renamed from: o.fVw, reason: case insensitive filesystem */
|
|
/* loaded from: classes6.dex */
|
|
public final class C13279fVw<T> extends AbstractC13163fSk<T> {
|
|
private InterfaceC13170fSr<T> d;
|
|
|
|
public C13279fVw(InterfaceC13170fSr<T> interfaceC13170fSr) {
|
|
this.d = interfaceC13170fSr;
|
|
}
|
|
|
|
@Override // o.AbstractC13163fSk
|
|
public final void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
|
|
Sts sts = new Sts(interfaceC13174fSv);
|
|
interfaceC13174fSv.onSubscribe(sts);
|
|
try {
|
|
this.d.b(sts);
|
|
} catch (Throwable th) {
|
|
C13147fSI.c(th);
|
|
if (sts.e(th)) {
|
|
return;
|
|
}
|
|
C13418fZu.c(th);
|
|
}
|
|
}
|
|
|
|
/* renamed from: o.fVw$Sts */
|
|
/* loaded from: classes6.dex */
|
|
static final class Sts<T> extends AtomicReference<fSJ> implements InterfaceC13168fSp<T>, fSJ {
|
|
private InterfaceC13174fSv<? super T> d;
|
|
|
|
Sts(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
|
|
this.d = interfaceC13174fSv;
|
|
}
|
|
|
|
@Override // o.InterfaceC13156fSd
|
|
public final void e(T t) {
|
|
if (t == null) {
|
|
NullPointerException c = fYR.c("onNext called with a null value.");
|
|
if (e((Throwable) c)) {
|
|
return;
|
|
}
|
|
C13418fZu.c(c);
|
|
return;
|
|
}
|
|
if (isDisposed()) {
|
|
return;
|
|
}
|
|
this.d.onNext(t);
|
|
}
|
|
|
|
@Override // o.InterfaceC13156fSd
|
|
public final void c(Throwable th) {
|
|
if (e(th)) {
|
|
return;
|
|
}
|
|
C13418fZu.c(th);
|
|
}
|
|
|
|
public final boolean e(Throwable th) {
|
|
if (th == null) {
|
|
th = fYR.c("onError called with a null Throwable.");
|
|
}
|
|
if (isDisposed()) {
|
|
return false;
|
|
}
|
|
try {
|
|
this.d.onError(th);
|
|
dispose();
|
|
return true;
|
|
} catch (Throwable th2) {
|
|
dispose();
|
|
throw th2;
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC13156fSd
|
|
public final void c() {
|
|
if (isDisposed()) {
|
|
return;
|
|
}
|
|
try {
|
|
this.d.onComplete();
|
|
} finally {
|
|
dispose();
|
|
}
|
|
}
|
|
|
|
@Override // o.InterfaceC13168fSp
|
|
public final void d(fSJ fsj) {
|
|
EnumC13192fTf.d((AtomicReference<fSJ>) this, fsj);
|
|
}
|
|
|
|
@Override // o.InterfaceC13168fSp
|
|
public final void a(fSR fsr) {
|
|
EnumC13192fTf.d((AtomicReference<fSJ>) this, (fSJ) new C13191fTe(fsr));
|
|
}
|
|
|
|
@Override // o.fSJ
|
|
public final void dispose() {
|
|
EnumC13192fTf.e(this);
|
|
}
|
|
|
|
@Override // o.InterfaceC13168fSp, 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());
|
|
}
|
|
}
|
|
}
|