public MqttSubscription()

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

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

        public MqttSubscription(Subscriber<? super T> subscriber) {
            this.subscriber = subscriber;
            this.subScribed = new AtomicBoolean(false);
        }