close method

Future<void> close()

Cancels every subscription and closes the broker.

Implementation

Future<void> close() async {
  for (final subscription in _subscriptions) {
    try {
      await subscription.cancel();
    } catch (_) {}
  }
  _subscriptions.clear();

  await broker.close();
}