public void request()

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

• 16 lines of code
• 4 McCabe index (conditional complexity)

    public void request(long n) {
        if (isTerminated()) {
            return;
        }

        if (n <= 0) {
            subscriber.onError(new IllegalArgumentException("Non-positive request signals are illegal"));
        }

        AtomicBoolean startTask = new AtomicBoolean(false);
        synchronized (this) {
            requestN.addAndGet(n);
            startTask.set(startTask());
        }

        if (startTask.get()) {
            handleRequests();
        }
    }