java - 如何编写HttpChunkedInput/ChunkedStream？

Question

我有以下完美运行的代码:

sendHeaders(obj)
setChunked()
sendRequestMessage()

context.write(DefaultFileRegion(obj.file, 0L, obj.file.length()))
context.writeAndFlush(LastHttpContent.EMPTY_LAST_CONTENT)

但是如果我发送

context.writeAndFlush(HttpChunkedInput(ChunkedStream(obj.stream().buffered())))

然后我得到 UnsupportedOperationExcpetion 因为 HttpChunkedInput 不受支持。但有很多例子(至少HttpStaticFileServerHandler)，所以它们做了同样的事情并且有效。为什么？

Answer 1

我只是忘记将 ChunkedWriteHandler 添加到管道

addLast("streamer", ChunkedWriteHandler())