asyncListen method

StreamSubscription<T> asyncListen(
  1. Future<void> onData(
    1. T event
    )
)

Implementation

StreamSubscription<T> asyncListen(
  Future<void> Function(T event) onData,
) {
  return asyncMap(
    (value) async {
      await onData(value);
      return value;
    },
  ).listen(ignore1);
}