@Internal public class DefaultStreamedHttpRequest extends io.netty.handler.codec.http.DefaultHttpRequest implements StreamedHttpRequest
Constructor and Description |
---|
DefaultStreamedHttpRequest(io.netty.handler.codec.http.HttpVersion httpVersion,
io.netty.handler.codec.http.HttpMethod method,
String uri,
boolean validateHeaders,
Publisher<io.netty.handler.codec.http.HttpContent> stream) |
DefaultStreamedHttpRequest(io.netty.handler.codec.http.HttpVersion httpVersion,
io.netty.handler.codec.http.HttpMethod method,
String uri,
Publisher<io.netty.handler.codec.http.HttpContent> stream) |
Modifier and Type | Method and Description |
---|---|
void |
subscribe(Subscriber<? super io.netty.handler.codec.http.HttpContent> subscriber) |
equals, getMethod, getUri, hashCode, method, setMethod, setProtocolVersion, setUri, toString, uri
getProtocolVersion, headers, protocolVersion
decoderResult, getDecoderResult, setDecoderResult
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getMethod, getUri, method, setMethod, setProtocolVersion, setUri, uri
public DefaultStreamedHttpRequest(io.netty.handler.codec.http.HttpVersion httpVersion, io.netty.handler.codec.http.HttpMethod method, String uri, Publisher<io.netty.handler.codec.http.HttpContent> stream)
httpVersion
- The Http Versionmethod
- The Http Methoduri
- The URIstream
- The publisherpublic DefaultStreamedHttpRequest(io.netty.handler.codec.http.HttpVersion httpVersion, io.netty.handler.codec.http.HttpMethod method, String uri, boolean validateHeaders, Publisher<io.netty.handler.codec.http.HttpContent> stream)
httpVersion
- The Http Versionmethod
- The Http Methoduri
- The URIvalidateHeaders
- Whether to validate the headersstream
- The publisherpublic void subscribe(Subscriber<? super io.netty.handler.codec.http.HttpContent> subscriber)