I am trying to decode the bytes in the contents of an HTTP response into a series of records. I was hoping to use the ReplayingDecoder in the following pipeline HttpResponseDecoder -> ReplayingDecoder. However, I cannot since ReplayingDecoder.decode() expects a ByteBuf, but the HttpResponseDecoder produces HttpContent objects. Is there any way to use a ReplayingDecoder in this context?
问问题
126 次