dispose method

  1. @override
Future<void> dispose()
override

Implementation

@override
Future<void> dispose() async {
  await disconnect();
  for (final s in _subscriptions) {
    await s.cancel();
  }
  unawaited(_states.close());
  unawaited(_discovered.close());
  unawaited(_disconnected.close());
  unawaited(_notifications.close());
}