ktor-http-cio/io.ktor.http.cio/startConnectionPipeline

startConnectionPipeline

fun CoroutineScope.startConnectionPipeline(input: ByteReadChannel, output: ByteWriteChannel, timeout: WeakTimeoutQueue, handler: suspend CoroutineScope.(request: Request, input: ByteReadChannel, output: ByteWriteChannel, upgraded: CompletableDeferred<Boolean>?) -> Unit): Job
Content copied to clipboard

Start connection HTTP pipeline invoking handler for every request. Note that handler could be invoked multiple times concurrently due to HTTP pipeline nature

Return

pipeline job

Parameters

input

incoming channel

output

outgoing bytes channel

timeout

number of IDLE seconds after the connection will be closed

handler

to be invoked for every incoming request