@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 |
closeIfNoSubscriber()
Releases the stream if there is no subscriber.
|
boolean |
isConsumed()
Has the stream been consumed.
|
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 boolean isConsumed()
StreamedHttpRequest
isConsumed
in interface StreamedHttpRequest
public void subscribe(Subscriber<? super io.netty.handler.codec.http.HttpContent> subscriber)
public void closeIfNoSubscriber()
StreamedHttpRequest
closeIfNoSubscriber
in interface StreamedHttpRequest