package io.reactivex.internal.subscriptions; import io.reactivex.internal.fuseable.QueueSubscription; import java.util.concurrent.atomic.AtomicInteger; import org.reactivestreams.Subscriber; /* loaded from: classes2.dex */ public final class ScalarSubscription extends AtomicInteger implements QueueSubscription { static final int CANCELLED = 2; static final int NO_REQUEST = 0; static final int REQUESTED = 1; private static final long serialVersionUID = -3830916580126663321L; final Subscriber subscriber; final T value; public ScalarSubscription(Subscriber subscriber, T t) { this.subscriber = subscriber; this.value = t; } @Override // org.reactivestreams.Subscription public void cancel() { lazySet(2); } @Override // io.reactivex.internal.fuseable.SimpleQueue public void clear() { lazySet(1); } public boolean isCancelled() { return get() == 2; } @Override // io.reactivex.internal.fuseable.SimpleQueue public boolean isEmpty() { return get() != 0; } @Override // io.reactivex.internal.fuseable.SimpleQueue public boolean offer(T t) { throw new UnsupportedOperationException("Should not be called!"); } @Override // io.reactivex.internal.fuseable.SimpleQueue public T poll() { if (get() != 0) { return null; } lazySet(1); return this.value; } @Override // org.reactivestreams.Subscription public void request(long j) { if (SubscriptionHelper.validate(j) && compareAndSet(0, 1)) { Subscriber subscriber = this.subscriber; subscriber.onNext(this.value); if (get() != 2) { subscriber.onComplete(); } } } @Override // io.reactivex.internal.fuseable.QueueFuseable public int requestFusion(int i) { return i & 1; } public boolean offer(T t, T t2) { throw new UnsupportedOperationException("Should not be called!"); } }