Jeziel Lago
05/11/2021, 6:12 PMrepeat
with some Flow operator?ephemient
05/13/2021, 4:14 AMfun <T> Flow<T>.repeat(): Flow<T> = flow {
while (true) emitAll(this@repeat)
}
Jeziel Lago
05/13/2021, 11:09 AMfun <T> Flow<T>.repeat(times: Int): Flow<T> = flow {
repeat (times) { emitAll(this@repeat) }
}
Jeziel Lago
05/13/2021, 10:52 PMephemient
05/13/2021, 10:57 PMpublic fun <T> Flow<T>.repeatUntil(condition: () -> Boolean): Flow<T>
should take a suspend () -> Boolean
lambda, at least… maybe even suspend FlowCollector<T>.() -> Boolean