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?
