io.micronaut.http.netty.stream

Class DefaultStreamedHttpResponse

java.lang.Object

io.netty.handler.codec.http.DefaultHttpObject

io.netty.handler.codec.http.DefaultHttpMessage

io.netty.handler.codec.http.DefaultHttpResponse

io.micronaut.http.netty.stream.DefaultStreamedHttpResponse

All Implemented Interfaces:

StreamedHttpMessage, StreamedHttpResponse, io.netty.handler.codec.DecoderResultProvider, io.netty.handler.codec.http.HttpMessage, io.netty.handler.codec.http.HttpObject, io.netty.handler.codec.http.HttpResponse, org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent>

@Internal
public class DefaultStreamedHttpResponse
extends io.netty.handler.codec.http.DefaultHttpResponse
implements StreamedHttpResponse

A default streamed HTTP response.

Since:

1.0

Author:

jroper, Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
DefaultStreamedHttpResponse(io.netty.handler.codec.http.HttpVersion version, io.netty.handler.codec.http.HttpResponseStatus status, boolean validateHeaders, org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream)
DefaultStreamedHttpResponse(io.netty.handler.codec.http.HttpVersion version, io.netty.handler.codec.http.HttpResponseStatus status, io.netty.handler.codec.http.HttpHeaders headers, org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream)
DefaultStreamedHttpResponse(io.netty.handler.codec.http.HttpVersion version, io.netty.handler.codec.http.HttpResponseStatus status, org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super io.netty.handler.codec.http.HttpContent> subscriber)

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

equals, getStatus, hashCode, setProtocolVersion, setStatus, status, toString

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

getStatus, setProtocolVersion, setStatus, status

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

DefaultStreamedHttpResponse

public DefaultStreamedHttpResponse(io.netty.handler.codec.http.HttpVersion version,
                                   io.netty.handler.codec.http.HttpResponseStatus status,
                                   org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream)

Parameters:

version - The Http Version

status - The Http response status

stream - The publisher

DefaultStreamedHttpResponse

public DefaultStreamedHttpResponse(io.netty.handler.codec.http.HttpVersion version,
                                   io.netty.handler.codec.http.HttpResponseStatus status,
                                   boolean validateHeaders,
                                   org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream)

Parameters:

version - The Http Version

status - The Http response status

validateHeaders - Whether to validate the headers

stream - The publisher

DefaultStreamedHttpResponse

public DefaultStreamedHttpResponse(io.netty.handler.codec.http.HttpVersion version,
                                   io.netty.handler.codec.http.HttpResponseStatus status,
                                   io.netty.handler.codec.http.HttpHeaders headers,
                                   org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream)

Parameters:

version - The Http Version

status - The Http response status

headers - The Http headers

stream - The publisher

Method Detail

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>