Is mixing coroutines with fx discouraged? I'm doing so in my ktor app (well because ktor uses corout...

# arrow

[kartoffelsup]

Is mixing coroutines with fx discouraged? I'm doing so in my ktor app (well because ktor uses coroutines :D) would the alternative be to use something other than ktor?

[bitnot]

have you seen this page https://arrow-kt.io/docs/0.10/integrations/kotlinxcoroutines/ ?

[kartoffelsup]

Ah 😄 No not yet. Looks like exactly what I need.

[than_]

inline fun <reified T : Any> Route.get(noinline body: suspend ConcurrentSyntax<ForIO>.(call: ApplicationCall, args: T) -> Unit): Route =
    get<T> {
        IO.fx {
            body(call, it)
        }.suspendCancellable()
    }

[than_]

now Ktor uses IO 🙂

[kartoffelsup]

Yes that's what I already do. But it looks hacky 😄

[than_]

because of the IO > coroutines boundary crossing?

[kartoffelsup]

Yeah I guess that's it what feels off about it. https://github.com/kartoffelsup/nuntius/blob/master/adapters/src/main/kotlin/io/github/kartoffelsup/nuntius/Routes.kt#L80-L118 - this is what I'm doing and I mean it works but it feels wrong? Not sure how to explain it 😄

[raulraja]

https://www.47deg.com/blog/arrow-kotlinx-integration/

[raulraja]

If you wrap your routes on IO you can compose them easier. This is some code with the 0.11 snapshot

[kartoffelsup]

Yes that looks a lot nicer, thanks! 🙂

[raulraja]

ktor.route.kt

[raulraja]

suspendCancellable is now in Arrow I believe

[raulraja]

but that is what it looks like

[raulraja]

then you can do things like

[raulraja]

config.ktor.kt

[raulraja]

embedded.io.server.kt

[raulraja]

those functions will eventually make it to a ktor integration module if they are not already there

[raulraja]

The key is to embrace IO / suspend all the way to main

[kartoffelsup]

Ah, so this shifts the unsafe part from each route to main?

[simon.vergauwen]

There is nothing dangerous about doing so. And all KotlinX features can still be used 👍

[Satyam Agarwal]

@raulraja I’ve already bumped to 0.10.5, though suspendCancellable is there, it doesn’t have the same implementation as in 0.11.0. Anyway, The snippet you posted <http://embedded.io|embedded.io>.server.kt in that there is

GlobalScope.KtorEmbeddedServer

thats basically

GlobalScope.embeddedServer

right ?
because KtorEmbeddedServer is unresolved, so I am guessing it was just to illustrate ?

[Satyam Agarwal]

And TaskOf<Unit> is also unresolved.

[starke]

The key is to embrace IO / suspend all the way to main

@raulraja are there any examples of how that would look for an android app?

[aballano]

@starke yes, one example you have from our colleague @Jorge Castillo https://github.com/JorgeCastilloPrz/ArrowAndroidSamples

and there’s even an article posted recently explaining it https://medium.com/default-to-open/explaining-the-arrow-android-sample-ee5c8bdfe88a

[starke]

thank you! I’ll check those out