onClose method
Call this to dispose the service, cancels all streams and removes all subscribers
Implementation
Future<void> onClose() async {
for (var item in _streamSubs.values) {
await item.cancel();
}
_notificationSubscribers.clear();
}