disconnectAll method

Future<void> disconnectAll()

Disconnects from all peers

Implementation

Future<void> disconnectAll() async {
  final clientList = List<StompClient>.from(_clients.values);
  _clients.clear();

  for (final client in clientList) {
    await client.disconnect();
  }

  _logger.info('Disconnected from all STOMP servers');
}