       .filter { message in
         return message.topic == topic
       }
-      .debug()
   }
   
 }
      }
    }

    mqttSession.connectAndWaitTimeout(30)

    return source.promise
  }

    let mqttTransport: MQTTCFSocketTransport
    let mqttSession: MQTTSession
    var delegate: MqttHomeDelegate? = nil
    var currentObserver: AnyObserver<Message>? = nil

    mqttTransport = MQTTCFSocketTransport()
    mqttTransport.host = host
