A modern programming language that makes developers happier.

kotlinlang

Hey all, I'm working on `Flow.retry` using `Schedule` you can find the PR here: <https://github.com/arrow-kt/arrow-fx/pull/378>

It's built atop the `Flow.retryWhen` operator and it seems to be working.... am I on the right path? any ideas how to test the `delay`  part then retrying?

Looking at the tests in Flow one could add delay within the Schedule on 2 flows zip them together and then you could reason on that <https://github.com/Kotlin/kotlinx.coroutines/blob/9587590fc003bcd8271a5388075e116c61fb26f5/kotlinx-coroutines-core/common/test/flow/operators/ZipTest.kt#L17|https://github.com/Kotlin/kotlinx.coroutines/blob/9587590fc003bcd8271a5388075e116c[…]5/kotlinx-coroutines-core/common/test/flow/operators/ZipTest.kt>
the combine tests are similar <https://github.com/Kotlin/kotlinx.coroutines/blob/9587590fc003bcd8271a5388075e116c61fb26f5/kotlinx-coroutines-core/common/test/flow/operators/CombineTest.kt#L21|https://github.com/Kotlin/kotlinx.coroutines/blob/9587590fc003bcd8271a5388075e116c[…]tlinx-coroutines-core/common/test/flow/operators/CombineTest.kt>

combine is like mapN <https://github.com/Kotlin/kotlinx.coroutines/blob/9587590fc003bcd8271a5388075e116c61fb26f5/kotlinx-coroutines-core/common/src/flow/operators/Zip.kt#L32|https://github.com/Kotlin/kotlinx.coroutines/blob/9587590fc003bcd8271a5388075e116c[…]fb26f5/kotlinx-coroutines-core/common/src/flow/operators/Zip.kt>

Thanks Imran, I will take a look at the links you shared