<@U0B8UEMV1> <@U0RM4EPC7> I tried following your l...

# arrow

[kluck]

@pakoito @simon.vergauwen I tried following your lead, but my tests keep running indefinitely. Here's my code for now:

fun <Type> IO<Type>.useCase(ok: (Type) -> Unit, error: (Throwable) -> Unit): IO<Unit> = fx {
    Dispatchers.IO.shift().flatMap { this@useCase }.continueOn(Dispatchers.Main).map(ok).handleError(error).bind()
}

While debugging, I can see that my IO gets executed on DefaultDispatcher-worker-1, but it never seems to reach my ok or error lambda