public void cancel()

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

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

        public void cancel() {
            try {
                if (subScribed.compareAndSet(true, false)) {
                    client.unsubscribe(topic);
                }
            } catch (MqttException e) {
                subscriber.onError(e);
            }
        }