package f.a.w.e.d;

import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: compiled from: ObservableScalarXMap.java */
/* JADX INFO: loaded from: classes.dex */
public final class b0<T> extends AtomicInteger implements f.a.w.c.a<T>, Runnable {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final f.a.n<? super T> f3769b;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final T f3770e;

    public b0(f.a.n<? super T> nVar, T t) {
        this.f3769b = nVar;
        this.f3770e = t;
    }

    @Override // f.a.w.c.d
    public void clear() {
        lazySet(3);
    }

    @Override // f.a.t.b
    public void dispose() {
        set(3);
    }

    @Override // f.a.w.c.d
    public boolean isEmpty() {
        return get() != 1;
    }

    @Override // f.a.w.c.d
    public boolean offer(T t) {
        throw new UnsupportedOperationException("Should not be called!");
    }

    @Override // f.a.w.c.d
    public T poll() throws Exception {
        if (get() != 1) {
            return null;
        }
        lazySet(3);
        return this.f3770e;
    }

    @Override // f.a.w.c.a
    public int requestFusion(int i2) {
        if ((i2 & 1) == 0) {
            return 0;
        }
        lazySet(1);
        return 1;
    }

    @Override // java.lang.Runnable
    public void run() {
        if (get() == 0 && compareAndSet(0, 2)) {
            this.f3769b.c(this.f3770e);
            if (get() == 2) {
                lazySet(3);
                this.f3769b.onComplete();
            }
        }
    }
}