io.netty.example.http2.client

Class HttpResponseHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.FullHttpResponse>

io.netty.example.http2.client.HttpResponseHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler

public class HttpResponseHandler
extends io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.FullHttpResponse>

Process FullHttpResponse translated from HTTP/2 frames

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable, io.netty.channel.ChannelHandler.Skip

Constructor Summary

Constructors

Constructor and Description
HttpResponseHandler()

Method Summary

Methods

Modifier and Type	Method and Description
void	awaitResponses(long timeout, TimeUnit unit) Wait (sequentially) for a time duration for each anticipated response
protected void	messageReceived(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.FullHttpResponse msg)
io.netty.channel.ChannelPromise	put(int streamId, io.netty.channel.ChannelPromise promise) Create an association between an anticipated response stream id and a ChannelPromise

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

bind, channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, close, connect, deregister, disconnect, exceptionCaught, flush, handlerAdded, handlerRemoved, isSharable, read, userEventTriggered, write

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpResponseHandler

public HttpResponseHandler()

Method Detail

put

public io.netty.channel.ChannelPromise put(int streamId,
                                  io.netty.channel.ChannelPromise promise)

Create an association between an anticipated response stream id and a ChannelPromise

Parameters:

streamId - The stream for which a response is expected

promise - The promise object that will be used to wait/notify events

Returns:

The previous object associated with streamId

See Also:

awaitResponses(long, TimeUnit)

awaitResponses

public void awaitResponses(long timeout,
                  TimeUnit unit)

Wait (sequentially) for a time duration for each anticipated response

Parameters:

timeout - Value of time to wait for each response

unit - Units associated with timeout

See Also:

put(int, ChannelPromise)

messageReceived

protected void messageReceived(io.netty.channel.ChannelHandlerContext ctx,
                   io.netty.handler.codec.http.FullHttpResponse msg)
                        throws Exception

Specified by:

messageReceived in class io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.FullHttpResponse>

Throws:

Exception