class DeferredScalarSubscription extends BasicIntQueueSubscription<T> {

    @Override
    public void cancel() {
        set(CANCELLED);
        value = null;
    }

    public  DeferredScalarSubscription(Subscriber<? super T> actual);

}