io.micronaut.http.netty.stream

Interface StreamedHttpRequest

All Superinterfaces:

io.netty.handler.codec.DecoderResultProvider, 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

public interface StreamedHttpRequest
extends io.netty.handler.codec.http.HttpRequest, StreamedHttpMessage

Combines HttpRequest and StreamedHttpMessage into one message. So it represents an http request with a stream of HttpContent messages that can be subscribed to.

Author:

jroper, Graeme Rocher

Method Summary

Modifier and Type	Method and Description
default void	closeIfNoSubscriber() Releases the stream if there is no subscriber.
default boolean	isConsumed() Has the stream been consumed.

Methods inherited from interface io.netty.handler.codec.http.HttpRequest

getMethod, getUri, method, setMethod, setProtocolVersion, setUri, uri

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.DecoderResultProvider

decoderResult, setDecoderResult

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Method Detail

closeIfNoSubscriber

default void closeIfNoSubscriber()

Releases the stream if there is no subscriber.

isConsumed

default boolean isConsumed()

Has the stream been consumed.

Returns:

True if it has