Package org.asynchttpclient.netty.request

Class NettyRequestSender

java.lang.Object

org.asynchttpclient.netty.request.NettyRequestSender

public final class NettyRequestSender
extends Object

Constructor Summary

Constructors

Constructor	Description
NettyRequestSender(AsyncHttpClientConfig config, ChannelManager channelManager, io.netty.util.Timer nettyTimer, AsyncHttpClientState clientState)

Method Summary

Modifier and Type	Method	Description
void	abort(io.netty.channel.Channel channel, NettyResponseFuture<?> future, Throwable t)
boolean	applyIoExceptionFiltersAndReplayRequest(NettyResponseFuture<?> future, IOException e, io.netty.channel.Channel channel)
void	drainChannelAndExecuteNextRequest(io.netty.channel.Channel channel, NettyResponseFuture<?> future, Request nextRequest)
void	drainChannelAndExecuteNextRequest(io.netty.channel.Channel channel, NettyResponseFuture<?> future, Request nextRequest, io.netty.util.concurrent.Future<io.netty.channel.Channel> whenHandshaked)
void	handleUnexpectedClosedChannel(io.netty.channel.Channel channel, NettyResponseFuture<?> future)
boolean	isClosed()
void	replayRequest(NettyResponseFuture<?> future, FilterContext fc, io.netty.channel.Channel channel)
boolean	retry(NettyResponseFuture<?> future)
void	sendHttp2RequestBody(NettyResponseFuture<?> future, io.netty.handler.codec.http2.Http2StreamChannel streamChannel)	Sends the body of an HTTP/2 request whose HEADERS were already written with endStream=false because it carried Expect: 100-continue.
<T> void	sendNextRequest(Request request, NettyResponseFuture<T> future)
<T> ListenableFuture<T>	sendRequest(Request request, AsyncHandler<T> asyncHandler, NettyResponseFuture<T> future)
<T> void	writeRequest(NettyResponseFuture<T> future, io.netty.channel.Channel channel)

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyRequestSender

public NettyRequestSender(AsyncHttpClientConfig config,
                          ChannelManager channelManager,
                          io.netty.util.Timer nettyTimer,
                          AsyncHttpClientState clientState)

Method Detail

sendRequest

public <T> ListenableFuture<T> sendRequest(Request request,
                                           AsyncHandler<T> asyncHandler,
                                           NettyResponseFuture<T> future)

writeRequest

public <T> void writeRequest(NettyResponseFuture<T> future,
                             io.netty.channel.Channel channel)

sendHttp2RequestBody

public void sendHttp2RequestBody(NettyResponseFuture<?> future,
                                 io.netty.handler.codec.http2.Http2StreamChannel streamChannel)
                          throws IOException

Sends the body of an HTTP/2 request whose HEADERS were already written with endStream=false because it carried Expect: 100-continue. Invoked by Continue100Interceptor once the server's 100 (Continue) arrives: writes the body as DATA frame(s) with endStream=true and releases the request.

Throws:

IOException

abort

public void abort(io.netty.channel.Channel channel,
                  NettyResponseFuture<?> future,
                  Throwable t)

handleUnexpectedClosedChannel

public void handleUnexpectedClosedChannel(io.netty.channel.Channel channel,
                                          NettyResponseFuture<?> future)

retry

public boolean retry(NettyResponseFuture<?> future)

applyIoExceptionFiltersAndReplayRequest

public boolean applyIoExceptionFiltersAndReplayRequest(NettyResponseFuture<?> future,
                                                       IOException e,
                                                       io.netty.channel.Channel channel)

sendNextRequest

public <T> void sendNextRequest(Request request,
                                NettyResponseFuture<T> future)

replayRequest

public void replayRequest(NettyResponseFuture<?> future,
                          FilterContext fc,
                          io.netty.channel.Channel channel)

isClosed

public boolean isClosed()

drainChannelAndExecuteNextRequest

public void drainChannelAndExecuteNextRequest(io.netty.channel.Channel channel,
                                              NettyResponseFuture<?> future,
                                              Request nextRequest)

drainChannelAndExecuteNextRequest

public void drainChannelAndExecuteNextRequest(io.netty.channel.Channel channel,
                                              NettyResponseFuture<?> future,
                                              Request nextRequest,
                                              io.netty.util.concurrent.Future<io.netty.channel.Channel> whenHandshaked)