class ScalarSubscription extends AtomicInteger implements QueueSubscription<T> {

    @Override
    public void request(long n) {
        if (!SubscriptionHelper.validate(n)) {
            return;
        }
        if (compareAndSet(NO_REQUEST, REQUESTED)) {
            Subscriber<? super T> s = subscriber;

            s.onNext(value);
            if (get() != CANCELLED) {
                s.onComplete();
            }
        }

    }

    public  ScalarSubscription(Subscriber<? super T> subscriber, T value);

}