once you're at that point when you have one of the...

# arrow

[pakoito]

once you're at that point when you have one of them, you can call callK.async(IO.async()).attempt() from the extensions package, or if you don't have that package write something like callK.async(IO.async()).map { Right(it) }.handleErrorWith { just(Left(it)) }, where IO.async() can be ObservableK.async() or DeferredK.async() depending on which one you want