async/stream_timeout_between_events library

Classes

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

WithTimeoutBetweenEvents on Stream<T>

Exceptions / Errors

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