Package io.micronaut.http.server.netty.handler

Class PipeliningServerHandler.OutboundAccessImpl

java.lang.Object

io.micronaut.http.server.netty.handler.PipeliningServerHandler.OutboundAccessImpl

All Implemented Interfaces:

NettyWriteContext, OutboundAccess

Enclosing class:

PipeliningServerHandler

public final class PipeliningServerHandler.OutboundAccessImpl
extends Object
implements OutboundAccess

Class that allows writing the response for the request this object is associated with.

Method Summary

Modifier and Type	Method	Description
io.netty.buffer.ByteBufAllocator	alloc()
void	attachment(Object attachment)	Set an attachment that is passed to RequestHandler.responseWritten(java.lang.Object).
void	closeAfterWrite()	Mark this channel to be closed after this response has been written.
void	writeFull(io.netty.handler.codec.http.FullHttpResponse response, boolean headResponse)	Write a full response.
void	writeStream(io.netty.handler.codec.http.HttpResponse response, InputStream stream, ExecutorService executorService)	Write a response with a body that is a blocking stream.
void	writeStreamed(io.netty.handler.codec.http.HttpResponse response, Publisher<io.netty.handler.codec.http.HttpContent> content)	Write a streamed response.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.http.netty.body.NettyWriteContext

writeFull

Method Details

alloc

public io.netty.buffer.ByteBufAllocator alloc()

Specified by:

alloc in interface NettyWriteContext

Returns:

The bytebuf allocator.

attachment

public void attachment(Object attachment)

Set an attachment that is passed to RequestHandler.responseWritten(java.lang.Object). Defaults to null.

Specified by:

attachment in interface OutboundAccess

Parameters:

attachment - The attachment to forward

closeAfterWrite

public void closeAfterWrite()

Mark this channel to be closed after this response has been written.

Specified by:

closeAfterWrite in interface OutboundAccess

writeFull

public void writeFull(io.netty.handler.codec.http.FullHttpResponse response,
 boolean headResponse)

Description copied from interface: NettyWriteContext

Write a full response.

Specified by:

writeFull in interface NettyWriteContext

Parameters:

response - The response to write

headResponse - If true, this is a response to a HEAD request, so the Content-Length header should not be overwritten.

writeStreamed

public void writeStreamed(io.netty.handler.codec.http.HttpResponse response,
 Publisher<io.netty.handler.codec.http.HttpContent> content)

Description copied from interface: NettyWriteContext

Write a streamed response.

Specified by:

writeStreamed in interface NettyWriteContext

Parameters:

response - The response to write

content - The body

writeStream

public void writeStream(io.netty.handler.codec.http.HttpResponse response,
 InputStream stream,
 ExecutorService executorService)

Description copied from interface: NettyWriteContext

Write a response with a body that is a blocking stream.

Specified by:

writeStream in interface NettyWriteContext

Parameters:

response - The response. Must not be a FullHttpResponse

stream - The stream to read from

executorService - The executor for IO operations