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:

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, org.reactivestreams.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 and Description
DefaultStreamedHttpRequest(io.netty.handler.codec.http.HttpVersion httpVersion, io.netty.handler.codec.http.HttpMethod method, java.lang.String uri, boolean validateHeaders, org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream)
DefaultStreamedHttpRequest(io.netty.handler.codec.http.HttpVersion httpVersion, io.netty.handler.codec.http.HttpMethod method, java.lang.String uri, org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream)

Method Summary

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(org.reactivestreams.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.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

Constructor Detail

DefaultStreamedHttpRequest

public DefaultStreamedHttpRequest(io.netty.handler.codec.http.HttpVersion httpVersion,
                                  io.netty.handler.codec.http.HttpMethod method,
                                  java.lang.String uri,
                                  org.reactivestreams.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,
                                  java.lang.String uri,
                                  boolean validateHeaders,
                                  org.reactivestreams.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 Detail

isConsumed

public boolean isConsumed()

Description copied from interface: StreamedHttpRequest

Has the stream been consumed.

Specified by:

isConsumed in interface StreamedHttpRequest

Returns:

True if it has

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super io.netty.handler.codec.http.HttpContent> subscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent>

closeIfNoSubscriber

public void closeIfNoSubscriber()

Description copied from interface: StreamedHttpRequest

Releases the stream if there is no subscriber.

Specified by:

closeIfNoSubscriber in interface StreamedHttpRequest