Class Netty4HttpRequestBodyStream

java.lang.Object
org.elasticsearch.http.netty4.Netty4HttpRequestBodyStream
All Implemented Interfaces:
Closeable, AutoCloseable, org.elasticsearch.core.Releasable, HttpBody, HttpBody.Stream

public class Netty4HttpRequestBodyStream extends Object implements HttpBody.Stream
Netty based implementation of HttpBody.Stream. This implementation utilize ChannelConfig.setAutoRead(boolean) to prevent entire payload buffering. But sometimes upstream can send few chunks of data despite autoRead=off. In this case chunks will be buffered until downstream calls HttpBody.Stream.next()