class StrictSubscriber extends AtomicInteger implements FlowableSubscriber<T>, Subscription {

    @Override
    public void request(long n) {
        if (n <= 0) {
            cancel();
            onError(new IllegalArgumentException("§3.9 violated: positive request amount required but it was " + n));
        } else {
            SubscriptionHelper.deferredRequest(s, requested, n);
        }
    }

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

}