Package org.asynchttpclient.netty.channel

Class NettyConnectListener<T>

java.lang.Object

org.asynchttpclient.netty.channel.NettyConnectListener<T>

public final class NettyConnectListener<T>
extends Object

Non Blocking connect.

Constructor Summary

Constructors

Constructor	Description
NettyConnectListener(NettyResponseFuture<T> future, NettyRequestSender requestSender, ChannelManager channelManager, ConnectionSemaphore connectionSemaphore)

Method Summary

Modifier and Type	Method	Description
void	onFailure(io.netty.channel.Channel channel, Throwable cause)	Replays the request only while it is unwritten: replaying one that was already written would send it twice.
void	onSuccess(io.netty.channel.Channel channel, InetSocketAddress remoteAddress)

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyConnectListener

public NettyConnectListener(NettyResponseFuture<T> future,
                            NettyRequestSender requestSender,
                            ChannelManager channelManager,
                            ConnectionSemaphore connectionSemaphore)

Method Detail

onSuccess

public void onSuccess(io.netty.channel.Channel channel,
                      InetSocketAddress remoteAddress)

onFailure

public void onFailure(io.netty.channel.Channel channel,
                      Throwable cause)

Replays the request only while it is unwritten: replaying one that was already written would send it twice.