Package io.micronaut.http.netty.stream
Interface StreamedHttpRequest
- All Superinterfaces:
io.netty.handler.codec.DecoderResultProvider
,HotObservable<io.netty.handler.codec.http.HttpContent>
,io.netty.handler.codec.http.HttpMessage
,io.netty.handler.codec.http.HttpObject
,io.netty.handler.codec.http.HttpRequest
,Publisher<io.netty.handler.codec.http.HttpContent>
,StreamedHttpMessage
- All Known Implementing Classes:
DefaultStreamedHttpRequest
,DelegateStreamedHttpRequest
public interface StreamedHttpRequest
extends io.netty.handler.codec.http.HttpRequest, StreamedHttpMessage, HotObservable<io.netty.handler.codec.http.HttpContent>
Combines
HttpRequest
and StreamedHttpMessage
into one
message. So it represents a http request with a stream of
HttpContent
messages that can be subscribed to.- Author:
- jroper, Graeme Rocher
-
Method Summary
Modifier and TypeMethodDescriptiondefault void
Releases the stream if there is no subscriber.default boolean
Has the stream been consumed.Methods inherited from interface io.netty.handler.codec.DecoderResultProvider
decoderResult, setDecoderResult
Methods inherited from interface io.netty.handler.codec.http.HttpMessage
getProtocolVersion, headers, protocolVersion
Methods inherited from interface io.netty.handler.codec.http.HttpObject
getDecoderResult
Methods inherited from interface io.netty.handler.codec.http.HttpRequest
getMethod, getUri, method, setMethod, setProtocolVersion, setUri, uri
-
Method Details
-
closeIfNoSubscriber
default void closeIfNoSubscriber()Releases the stream if there is no subscriber.- Specified by:
closeIfNoSubscriber
in interfaceHotObservable<io.netty.handler.codec.http.HttpContent>
-
isConsumed
default boolean isConsumed()Has the stream been consumed.- Returns:
- True if it has
-