Hello, want to learn about this. When using Channel.consumeEach or having callbackFlow with retry operation, and using delay inside any of these. It blocks everything from proceeding.
I have an action I want to retry, which right now is callbackFlow, but using delay inside seems to be cancelled or omitted when using inside retry block.
And I got exact same problem in consumeEach.
Interesting thing if I make sure my delay runs on another Dispatcher than the other pending action, it seems to work.
My coroutineScope =
coroutineScope(SupervisorJob() + <http://Dispatchers.IO|Dispatchers.IO>)
The end goal is execute action A, if it fails I want to wait 5 seconds and try again action A inside my callbackFlow. Bonus thing, also need to be able to cancel Job from collect Flow in parallell while waiting 5 seconds or join the coroutines if thats possible.