I’m trying to setup a middleware like chain for pr...

# ktor

[Tunji Dahunsi]

I’m trying to setup a middleware like chain for processing ktor client errors. Imagine a pipeline of
[ModelValidationHandler, AuthErrorHandler] and so on.

Similar to the Logging feature, I’ve implemented my handlers as HttpClientFeature<*, *>. The issue I’m having is once one of my handlers reads the content ByteReadChannel of the HttpResponse as a String , the channel is fully read, and no other Handler can read it.

I read the response like this:

val observer: ResponseHandler = { response ->
                try {
                    val message = response.content
                            .readRemaining()
                            .readText(charset = response.charset()?: Charsets.UTF_8)
                } catch (_: Throwable) {
                } 
            }

            ResponseObserver.install(ResponseObserver(observer), scope)

The Logging feature does not have this limitation. It can log the response, and I can still read it once. Am I consuming the wrong response?

[Tunji Dahunsi]

I figured it out, I should be using HttpResponse.readText()