Package io.micronaut.http.netty.stream

Class DefaultStreamedHttpRequest

java.lang.Object
io.netty.handler.codec.http.DefaultHttpObject
io.netty.handler.codec.http.DefaultHttpMessage
io.netty.handler.codec.http.DefaultHttpRequest
io.micronaut.http.netty.stream.DefaultStreamedHttpRequest
All Implemented Interfaces:
HotObservable<io.netty.handler.codec.http.HttpContent>, StreamedHttpMessage, StreamedHttpRequest, 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>
@Internal public class DefaultStreamedHttpRequest extends io.netty.handler.codec.http.DefaultHttpRequest implements StreamedHttpRequest
A default streamed HTTP request.
Since:
1.0
Author:
jroper, Graeme Rocher

  • Constructor Summary

    Constructors
    Constructor
    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)
     

  • Method Summary

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

    Methods inherited from class io.netty.handler.codec.http.DefaultHttpRequest

    equals, getMethod, getUri, hashCode, method, setMethod, setProtocolVersion, setUri, toString, uri

    Methods inherited from class io.netty.handler.codec.http.DefaultHttpMessage

    getProtocolVersion, headers, protocolVersion

    Methods inherited from class io.netty.handler.codec.http.DefaultHttpObject

    decoderResult, getDecoderResult, setDecoderResult

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    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

  • Constructor Details

    • DefaultStreamedHttpRequest

      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)
      Parameters:
      httpVersion - The Http Version
      method - The Http Method
      uri - The URI
      stream - The publisher

    • DefaultStreamedHttpRequest

      public 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)
      Parameters:
      httpVersion - The Http Version
      method - The Http Method
      uri - The URI
      validateHeaders - Whether to validate the headers
      stream - The publisher

  • Method Details