public void request()

in rcomp-mqtt/src/main/java/org/apache/karaf/rcomp/mqtt/MqttSource.java [56:64]

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

        public void request(long n) {
            try {
                if (subScribed.compareAndSet(false, true)) {
                    client.subscribe(topic, this);
                }
            } catch (MqttException e) {
                subscriber.onError(e);
            }
        }