takeFor

fun <T> Flow<T>.takeFor(duration: Duration): Flow<T>

Mirrors the upstream for duration, then completes.

Shorthand for takeUntil(timerFlow(duration)).

Throws