PhoenixSocket.swift

public func connect(with onConnect: @escaping () -> (), retryOnDisconnect: Bool = true) {
  
  guard let socket = socket else { return }
  
  self.retryOnDisconnect = retryOnDisconnect
  
  socket.onConnect = onConnect
  socket.onDisconnect = {[weak self] error in
    
    guard let weakSelf = self else { return }
    weakSelf.reconnect()
  }
  
  if !socket.isConnected {
    socket.connect()
  }
}

private func reconnect() {
  
  guard let socket = socket else { return }
  
  //try to reconnect after a delay
  if retryOnDisconnect == true {
    DispatchQueue.main.asyncAfter(deadline: .now() + WebSocket.reconnectInterval) {
      socket.connect()
    }
  }
}