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 an http request with a stream of HttpContent messages that can be subscribed to.
Author:
jroper, Graeme Rocher

  • Method Summary

    Modifier and Type
    Method
    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.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

    Methods inherited from interface org.reactivestreams.Publisher

    subscribe

  • Method Details

    • closeIfNoSubscriber

      default void closeIfNoSubscriber()
      Releases the stream if there is no subscriber.
      Specified by:
      closeIfNoSubscriber in interface HotObservable<io.netty.handler.codec.http.HttpContent>

    • isConsumed

      default boolean isConsumed()
      Has the stream been consumed.
      Returns:
      True if it has