Package com.linkedin.venice.router.streaming

Interface Summary

Interface	Description
StreamingCallback<T>
VeniceChunkedWriteHandler.WriteMessageCallback

Class Summary

Class	Description
NettyChunkedWriteHandler	This class was copied from ChunkedWriteHandler, and the only change we made here is to using ConcurrentLinkedQueue for NettyChunkedWriteHandler.queue since NettyChunkedWriteHandler.resumeTransfer() or NettyChunkedWriteHandler.discard(Throwable) could happen in any sequence with any parallelism because of scatter/gather logic in Venice Router.
SuccessfulStreamingResponse	Full response to indicate that all the sub responses are with good status: HttpResponseStatus.OK for streaming request.
VeniceChunkedResponse	This is the class to talk to VeniceChunkedWriteHandler to send back partial response.
VeniceChunkedWriteHandler	This class is the wrapper of ChunkedWriteHandler, and essentially it will introduce the following logic: 1.