what-the-bank/sources/o/fTO.java

82 lines
1.7 KiB
Java
Raw Permalink Normal View History

2024-07-27 18:17:47 +07:00
package o;
/* loaded from: classes6.dex */
public class fTO<T> extends AbstractC13183fTH<T> {
private T b;
public final InterfaceC13174fSv<? super T> c;
public fTO(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
this.c = interfaceC13174fSv;
}
@Override // o.InterfaceC13413fZp
public final int b(int i) {
if ((i & 2) == 0) {
return 0;
}
lazySet(8);
return 2;
}
public final void d(T t) {
int i = get();
if ((i & 54) != 0) {
return;
}
InterfaceC13174fSv<? super T> interfaceC13174fSv = this.c;
if (i == 8) {
this.b = t;
lazySet(16);
interfaceC13174fSv.onNext(null);
} else {
lazySet(2);
interfaceC13174fSv.onNext(t);
}
if (get() != 4) {
interfaceC13174fSv.onComplete();
}
}
public final void e(Throwable th) {
if ((get() & 54) != 0) {
C13418fZu.c(th);
} else {
lazySet(2);
this.c.onError(th);
}
}
@Override // o.InterfaceC13414fZq
public final T b() {
if (get() != 16) {
return null;
}
T t = this.b;
this.b = null;
lazySet(32);
return t;
}
@Override // o.InterfaceC13414fZq
public final boolean c() {
return get() != 16;
}
@Override // o.InterfaceC13414fZq
public final void e() {
lazySet(32);
this.b = null;
}
@Override // o.fSJ
public void dispose() {
set(4);
this.b = null;
}
@Override // o.fSJ
public final boolean isDisposed() {
return get() == 4;
}
}