dispose method
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());
}