49 lines
1.2 KiB
Java
49 lines
1.2 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.concurrent.atomic.AtomicReference;
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class fXV<T> extends AtomicReference<fSJ> implements InterfaceC13174fSv<T>, fSJ {
|
||
|
|
private AtomicReference<fSJ> b = new AtomicReference<>();
|
||
|
|
private InterfaceC13174fSv<? super T> c;
|
||
|
|
|
||
|
|
public fXV(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
|
||
|
|
this.c = interfaceC13174fSv;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public final void onSubscribe(fSJ fsj) {
|
||
|
|
if (EnumC13192fTf.a(this.b, fsj)) {
|
||
|
|
this.c.onSubscribe(this);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public final void onNext(T t) {
|
||
|
|
this.c.onNext(t);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public final void onError(Throwable th) {
|
||
|
|
dispose();
|
||
|
|
this.c.onError(th);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public final void onComplete() {
|
||
|
|
dispose();
|
||
|
|
this.c.onComplete();
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final void dispose() {
|
||
|
|
EnumC13192fTf.e(this.b);
|
||
|
|
EnumC13192fTf.e(this);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final boolean isDisposed() {
|
||
|
|
return this.b.get() == EnumC13192fTf.DISPOSED;
|
||
|
|
}
|
||
|
|
}
|