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())

HttpChunkedInput / ChunkedStream 怎么写？

How to write HttpChunkedInput / ChunkedStream?

java

netty