timedFlow

fun timedFlow(duration: Millis): Flow<Double>