infrastructure/repositories/runners/query_timeout_helpers library

Functions

streamWithQueryTimeout<T>({required Stream<T> source, required Duration? queryTimeout, required T onTimeoutItem}) → Stream<T>
Applies queryTimeout to source, yielding onTimeoutItem and cancelling the underlying subscription so native cleanup runs.