StreamQueueExtension<T> extension

Extension adding convenient execution wrapper to StreamQueue.

on

Methods

close({bool immediate = false}) → void

Available on StreamQueue<T>, provided by the StreamQueueExtension extension

Cancels the underlying event source.
execute(FutureOr<void> onEvent(T), {FutureOr<void> onError(Object e)?}) → Future<void>

Available on StreamQueue<T>, provided by the StreamQueueExtension extension

Executes this StreamQueue in an async loop invoking the provided onEvent on every T event happening.