resetListener method
void
resetListener()
Implementation
void resetListener() {
clearListener();
PluginManager.instance.pluginsMap.values
.whereType<PluggableWithStream>()
.forEach((element) {
final pluggable = element;
// ignore: cancel_subscriptions
final subscription = pluggable.stream.where((event) {
return pluggable.streamFilter(event);
}).listen((event) {
_pluggableMessageData[pluggable.name]!.increaseCounter();
_sendSink(pluggable);
});
_pluggableMessageData.update(pluggable.name, (old) {
old.subscription?.cancel();
return PluggableMessageInfo.subscription(subscription);
}, ifAbsent: () => PluggableMessageInfo.subscription(subscription));
});
}