public void request()

in rcomp-kafka/src/main/java/org/apache/karaf/rcomp/kafka/KafkaSource.java [99:104]

• 6 lines of code
• 1 McCabe index (conditional complexity)

        public void request(long n) {
            requested.addAndGet(n);
            synchronized (this) {
                notify();
            }
        }