Richard Schielek
11/22/2022, 1:06 PMval response = request.response()
val channel = response.toSendChannel(vertx)
response.headers().set("Transfer-Encoding", "chunked")
for (i in 1..10) {
delay(200)
channel.send(Buffer.buffer("""{"id": $i}"""))
channel.send(Buffer.buffer("\n"))
}
response.end().await()
Aleksei Tirman [JB]
11/22/2022, 2:56 PMApplicationCall.respondBytesWriter
method:
embeddedServer(Netty, port = 3333) {
routing {
get("/") {
call.respondBytesWriter {
for (i in 1..10) {
delay(200)
writeStringUtf8("""{"id": $i}""")
writeStringUtf8("\n")
flush()
}
}
}
}
}.start(wait = true)
Richard Schielek
11/22/2022, 3:46 PM