startConnectionPipeline
fun CoroutineScope.startConnectionPipeline(
input: ByteReadChannel,
output: ByteWriteChannel,
timeout: WeakTimeoutQueue,
handler: HttpRequestHandler
): Job
Start connection HTTP pipeline invoking handler for every request. Note that handler could be invoked multiple times concurrently due to HTTP pipeline nature
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
Return pipeline job