dispatch method

void dispatch(T args)

Implementation

void dispatch(T args) {
  final callbacks = List<SubscriptionCallback<T>>.of(_subs);

  for (final callback in callbacks) {
    if (!_subs.contains(callback)) {
      continue;
    }

    final keepListening = callback(args);

    if (keepListening != true) {
      _subs.remove(callback);
    }
  }
}