                                     }
                                     $0.removeValueForKey(newPeer.uuid)
                                   }
-      })
+                                })
+
     guard let newAdvertiser = advertiser else {
       errorHandler(ThaliCoreError.ConnectionFailed)
       return


  // MARK: - Public state

  /***/
  public var advertising: Bool {
    return currentAdvertiser?.advertising ?? false
  }

  // MARK: - Internal state

  /***/
  internal private(set) var advertisers: Atomic<[Advertiser]> = Atomic([])

  /***/
  internal private(set) var activeRelays: Atomic<[String: AdvertiserRelay]> = Atomic([:])

  /***/
  internal var didDisposeAdvertiserForPeerHandler: ((Peer) -> Void)?

  // MARK: - Private state

  /***/
  private var currentAdvertiser: Advertiser?

  /***/
  private let serviceType: String

  /***/
  private let disposeTimeout: NSTimeInterval

  // MARK: - Initialization

  /***/
  public init(serviceType: String, disposeAdvertiserTimeout: NSTimeInterval) {
    self.serviceType = serviceType
    self.disposeTimeout = disposeAdvertiserTimeout

                                    let relay = AdvertiserRelay(with: session, on: port)
                                    $0[newPeer.uuid] = relay
                                  }
                                },
                                sessionNotConnected: {
                                  [weak self] in
                                  guard let strongSelf = self else { return }
