MhuStreamX<T> extension

on

• Stream<T>

Methods

asyncForEach(FutureOr<void> action(T value)) → Future<void>

asyncListen(Future<void> onData(T event)) → StreamSubscription<T>