ReaderStream<T>.toReceiveChannel return elements in random order about vertx-lang-kotlin HOT 6 CLOSED

val resp = req.send(Buffer.buffer(query.body.readAllBytes())).await()
resp.endHandler {
    println("CLOSED")
    respCh.close()
}
resp.exceptionHandler {
    it.printStackTrace()
}
resp.handler {
    println(it.getString(0, 10) +"..."+ it.getString(it.length()-10, it.length()))
}  

=====START RECEIVE=====
\n purus S...citudin er
os. Donec ...:00:00 AM\
"} ], \"ip...e\": \"app
lication/v...:"^1[./0-9
$","profil...33030]}]}}
CLOSED

req.send(Buffer.buffer(query.body.readAllBytes())).onSuccess { resp ->
    resp.endHandler {
        println("CLOSED")
    }
    resp.exceptionHandler {
      it.printStackTrace()
    }
    resp.handler {
        println(it.getString(0, 10) +"..."+ it.getString(it.length()-10, it.length()))
    }
}

{"took":23...psum primi
s in fauci...","_id":"2
201756-2-0...ue dictum,
 efficitur...oncus vari
us. Aenean...uster":"te
st","sub_c...dimentum d
ui rutrum ...tricies, a
t vehicula...,\"connect
ion_data\"..., hendreri
t vestibul...68020]}]}}
CLOSED

suspend fun Future<HttpClientResponse>.await(): HttpClientResponse = when {
        succeeded() -> result().pause() <--- solution
        failed() -> throw cause()
        else -> suspendCancellableCoroutine { cont: CancellableContinuation<HttpClientResponse> ->
            onComplete { asyncResult ->
                if (asyncResult.succeeded()) cont.resume(asyncResult.result().pause()) <--- solution
                else cont.resumeWithException(asyncResult.cause())
            }
        }
}