WithTimeoutBetweenEvents<T> extension

on

• Stream<T>

Methods

withTimeoutBetweenEvents(Duration duration) → Stream<T>

Available on Stream<T>, provided by the WithTimeoutBetweenEvents extension

Adds a timeout between events of the stream. If the time between two consecutive events exceeds the specified duration, a TimeoutBetweenEventsException will be added to the stream.