Slackbot
05/16/2019, 3:29 PMJonathan Mew
05/16/2019, 3:32 PMproceed()
- equivalent to proceedWith(subject)
Cláudio Bartolomeu
05/16/2019, 3:46 PMsuspend fun HttpClient.forward(call: ApplicationCall) {
val exchange = this.call(call.request.uri) {
method = call.request.httpMethod
headers.appendAll(getValidHeaders(call.request.headers))
body = object : OutgoingContent.WriteChannelContent() {
override val contentType = call.request.contentType()
override suspend fun writeTo(channel: ByteWriteChannel) {
call.request.receiveChannel().copyAndClose(channel)
}
}
}
}
Jonathan Mew
05/16/2019, 3:52 PMclientFeatures.HttpClientExtensionsKt$forward$exchange$1$1
) as the argument for HttpClient.execute further on in the pipeline which fails.
suspend fun execute(builder: HttpRequestBuilder): HttpClientCall =
requestPipeline.execute(builder, builder.body) as HttpClientCall
Dico
05/16/2019, 9:34 PM