If anyone is using Ratpack I've added coroutine support for Kotlin app: https://github.com/gregopet/kotlin-ratpack-coroutines

(it's not very well tested yet and contributions are very welcome 😛 )

It's also very simple - looking at Ratpack's implementation of async and reading about Kotlin's coroutines it seems the two implementations are conceptually very similar, so I didn't have much work

quartz

- http://www.quartz-scheduler.org/

Any suggestions on async http libraries?

Client? Retrofit

try okhttp

Ahh, I must’ve read an old post saying that there’s no async with okhttp (which is why I was asking). Sweet! Retrofit + Java8 Call Adapter + Coroutines it is

okhttp isn't really async, is it? it uses threadpools under the hood

#ktor is incubating http client which is async (WIP)

vert.x client is supposed to be async...

Anybody using vertx with kotlin?

Hey folks! I'm willing to use Kotlin with #webflux to build a #graphql endpoint. There is any resource on that matter? Some sample project? Any advice?

@Leo i have no idea if it's any good, but i remember someone linking to this some time ago: https://github.com/bastman/skeleton-springboot-webflux-kotlin

Thank you @tipsy!

@tipsy how handle transaction in spring reactive application ?

@uesugi i have no idea, i actually hate spring

I haven't tried the new Spring reactive stuff, but can't you just use the normal transaction management that Spring offers?

guys, has anyone been successful in using the FreeMarker feature of Ktor in their Ktor projects recently?

it seems like, I can't install the feature

there is this instruction: http://ktor.io/features/freemarker.html

but I get:

the versions are

ktor_version = '0.9.1-alpha-8'

and

ktor-freemarker:0.4.0

Hey, anyone know what's wrong with this test?

@Test
    fun `Can register as an executor`() = runBlocking {
        val session = sessionFor("<ws://localhost:$port/ws/channel>")
        val msg = ObjectMapper().writeValueAsString(Message.executorConnected())
        session.send(session.textMessage(msg).toMono()).awaitFirst()
        Assertions.assertEquals(registry.getAll().size, 1)
        session.close().awaitFirst()
        Assertions.assertEquals(registry.getAll().size, 0)
    }

It's failing with

java.lang.NoClassDefFoundError: javax/websocket/ClientEndpointConfig$Configurator

and I'm at a loss as to what might be causing it

I'm using Spring 5/Spring Boot 2 with the webflux reactive starter

and it's not because of coroutines because I also wrote it in functional/promise style and it was still failing

The

sessionFor

method looks like so:

suspend fun sessionFor(url: String): WebSocketSession {
        val client = StandardWebSocketClient()
        var session: WebSocketSession? = null
        client.execute(URI(url)) {
            session = it
            Mono.empty()
        }.awaitFirst()
        return session!!
    }