48 lines
1.1 KiB
Java
48 lines
1.1 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.Queue;
|
||
|
|
import java.util.concurrent.atomic.AtomicReference;
|
||
|
|
|
||
|
|
/* renamed from: o.fTL, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class C13184fTL<T> extends AtomicReference<fSJ> implements InterfaceC13174fSv<T>, fSJ {
|
||
|
|
public static final Object a = new Object();
|
||
|
|
private Queue<Object> c;
|
||
|
|
|
||
|
|
public C13184fTL(Queue<Object> queue) {
|
||
|
|
this.c = queue;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public final void onSubscribe(fSJ fsj) {
|
||
|
|
EnumC13192fTf.a(this, fsj);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public final void onNext(T t) {
|
||
|
|
this.c.offer(fYX.d(t));
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public final void onError(Throwable th) {
|
||
|
|
this.c.offer(fYX.a(th));
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.InterfaceC13174fSv
|
||
|
|
public final void onComplete() {
|
||
|
|
this.c.offer(fYX.c());
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final void dispose() {
|
||
|
|
if (EnumC13192fTf.e(this)) {
|
||
|
|
this.c.offer(a);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final boolean isDisposed() {
|
||
|
|
return get() == EnumC13192fTf.DISPOSED;
|
||
|
|
}
|
||
|
|
}
|