82 lines
1.7 KiB
Java
82 lines
1.7 KiB
Java
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;
|
|
}
|
|
}
|