async/export_async library

Classes

ErrorAbsorberTransformer<T>

A StreamTransformer that absorbs errors, optionally emits a value, and then finishes the stream. If an error occurs, the onError callback is invoked to provide an optional value to emit before closing the stream.

TimeoutBetweenEvents<E>

A StreamTransformer that adds a timeout between events. If the time between two consecutive events exceeds the specified duration, a TimeoutBetweenEventsException will be added to the stream.

Extensions

BufferedStreamExtension on Stream<T>

CallWhen on T? Function()

Debounce on T? Function()

DelayedCall on T Function()

OnError on Future<T>

OnErrorFinishWith on Stream<T>

OnErrorNullable on Future<T?>

Periodic on T? Function()

TakeFor on Stream<T>

Throttle on T? Function()

UnwrapFuture on Future<T?>

UnwrapStream on Stream<T?>

WithTimeoutBetweenEvents on Stream<T>

Exceptions / Errors

TimeoutBetweenEventsException

Exception thrown when a timeout occurs between events in the stream.