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));
  });
}