through
fun <T> Flow<T>.throughTimeLimiter(timeLimiter: TimeLimiter, timeout: Duration? = null): Flow<T>(source)
Bounds collection of this Flow with a TimeLimiter: if the whole collection doesn't complete within the timeout, it is cancelled.