42 lines
1.1 KiB
Java
42 lines
1.1 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.Objects;
|
||
|
|
import java.util.concurrent.atomic.AtomicReference;
|
||
|
|
|
||
|
|
/* renamed from: o.fZf, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public abstract class AbstractC13403fZf<T> implements InterfaceC13174fSv<T>, fSJ {
|
||
|
|
private AtomicReference<fSJ> b = new AtomicReference<>();
|
||
|
|
|
||
|
|
public void c() {
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public final void onSubscribe(fSJ fsj) {
|
||
|
|
AtomicReference<fSJ> atomicReference = this.b;
|
||
|
|
Class<?> cls = getClass();
|
||
|
|
Objects.requireNonNull(fsj, "next is null");
|
||
|
|
while (!atomicReference.compareAndSet(null, fsj)) {
|
||
|
|
if (atomicReference.get() != null) {
|
||
|
|
fsj.dispose();
|
||
|
|
if (atomicReference.get() != EnumC13192fTf.DISPOSED) {
|
||
|
|
C13356fYM.b(cls);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
c();
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final boolean isDisposed() {
|
||
|
|
return this.b.get() == EnumC13192fTf.DISPOSED;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final void dispose() {
|
||
|
|
EnumC13192fTf.e(this.b);
|
||
|
|
}
|
||
|
|
}
|