     }
 
     internal func centralManagerDidUpdateState() {
-        discoveryManager.queue.assertIsDispatching()
+        queue.assertIsDispatching()
         switch centralManager.state {
         case .poweredOn:
             if autoReconnect {

    private var autoReconnect = false

    public required init(discoveryManager: BLEDiscoveryManager, peripheral: CBPeripheral) {
        discoveryManager.queue.assertIsDispatching()
        self.discoveryManager = discoveryManager
        self.uuid = peripheral.identifier
        super.init()

    }

    open func didFailToConnect(error: Error?) {
        queue.assertIsDispatching()
        guard let peripheral = peripheral else { return }
        assumeNotAdvertising()
        if connectionAttempt < type(of: self).connectionRetryCount {
