# ktor

Alexander Weickmann

11/22/2023, 5:28 PM
Hey all. I have created a ktor client plugin that logs the body of the http response received. However, when I do read that response body for logging it out, I also happen to consume the associated ByteReadChannel. Subsequent calls to bodyAsText() by the application itself (for example to show the error message on the UI) thus only return empty strings. Is it possible to somehow read the response body twice, or to restore the channel in the plugin after it was read?

Aleksei Tirman [JB]

11/22/2023, 6:05 PM
The issue (KTOR-4225) of double-consuming the response body is fixed in Ktor 3.0.0. You can use the
to make the subsequent calls to
return the actual body as a String.

Jaap Beetstra

11/22/2023, 6:09 PM
I had a similar issue and replaced the response received with a cached response. The relevant part looks like this
Copy code
        client.receivePipeline.intercept(HttpReceivePipeline.State) { response -> interceptReceive(response) }

private suspend fun PipelineContext<HttpResponse, Unit>.interceptReceive(response: HttpResponse) {
    val logIdValue = response.request.attributes[logId]
    val responseData = CachedHttpResponseData.create(response)
    proceedWith(CachedHttpResponse(, responseData, response.coroutineContext))

Alexander Weickmann

11/23/2023, 12:53 PM
Thanks for the info. Good to know that it will work out of the box in 3.0.0 @Jaap Beetstra I understand your example is for ktor 2.x? Where does that CachedHttpResponseData class come from?

Jaap Beetstra

11/23/2023, 6:36 PM
@Alexander Weickmann Yes it's Ktor 2.x. The CachedHttpResponseData class is a simple data class that stores the request.
Copy code
data class CachedHttpResponseData(val headers: CachedHttpHeaders, val body: String) {
    companion object {
        suspend fun create(response: HttpResponse) =
            CachedHttpResponseData(CachedHttpHeaders(response), response.bodyAsText())

data class CachedHttpHeaders(val statusCode: Int, val timestamp: Long, val headers: List<CachedHttpHeaderValue>) {
    constructor(response: HttpResponse) : this(
        response.status.value, response.responseTime.timestamp,
        response.headers.entries().flatMap { (name, values) ->
   { CachedHttpHeaderValue(name, it) }

data class CachedHttpHeaderValue(val name: String, val value: String)
CachedHttpResponse wraps the data class in a Ktor HttpResponse
Copy code
class CachedHttpResponse(
    override val call: HttpClientCall,
    response: CachedHttpResponseData,
    override val coroutineContext: CoroutineContext
) : HttpResponse() {
    override val content: ByteReadChannel = ByteReadChannel(response.body)
    override val headers: Headers = response.headers.headers.filterNot { == "content-encoding" }.toHeaders()
    override val requestTime: GMTDate = GMTDate(response.headers.timestamp)
    override val responseTime: GMTDate = GMTDate()
    override val status: HttpStatusCode = HttpStatusCode.fromValue(response.headers.statusCode)
    override val version: HttpProtocolVersion = HttpProtocolVersion.HTTP_1_1

private fun List<CachedHttpHeaderValue>.toHeaders(): Headers = HeadersBuilder().apply {
    forEach { header -> append(, header.value) }

Alexander Weickmann

11/28/2023, 8:42 AM
Cool, thank you very much. It works 👍
As I learned the hard way, it is actually not that easy The body is actually not always a string. So when you do a file download, bodyAsText does not work. You also don't want to cache a byte array instead of a string, because you might have a large file download that you don't want to copy to the heap Maybe I'll try to only do the above modifications to the pipeline if the content type is application/json or text/plain