public void onNext()

in oss-20190517/src/main/java/com/aliyun/sdk/service/oss20190517/paginator/async/LimitingSubscriber.java [27:35]

• 9 lines of code
• 3 McCabe index (conditional complexity)

    public void onNext(T t) {
        if (delivered.get() < limit) {
            subscriber.onNext(t);
        }
        if (delivered.incrementAndGet() >= limit) {
            subscription.cancel();
            subscriber.onComplete();
        }
    }