summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
1581d8d)
Channel is an invariant, hence we do not need to dereference
ChannelFuture, allowing us to reduce verbosity quite a bit.
Change-Id: Ifa9b9b89e1841479f3e66141e02b2619492f3900
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
import static java.util.Objects.requireNonNull;
import io.netty.channel.Channel;
import static java.util.Objects.requireNonNull;
import io.netty.channel.Channel;
-import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.handler.ssl.SslHandler;
import io.netty.util.Timeout;
import io.netty.util.Timer;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.handler.ssl.SslHandler;
import io.netty.util.Timeout;
import io.netty.util.Timer;
-import io.netty.util.concurrent.GenericFutureListener;
import io.netty.util.concurrent.Promise;
import java.util.Optional;
import java.util.concurrent.TimeUnit;
import io.netty.util.concurrent.Promise;
import java.util.Optional;
import java.util.concurrent.TimeUnit;
connectionTimeoutMillis);
changeState(State.FAILED);
connectionTimeoutMillis);
changeState(State.FAILED);
- channel.close().addListener((GenericFutureListener<ChannelFuture>) future -> {
+ channel.close().addListener(future -> {
if (future.isSuccess()) {
if (future.isSuccess()) {
- LOG.debug("Channel {} closed: success", future.channel());
+ LOG.debug("Channel {} closed: success", channel);
- LOG.warn("Channel {} closed: fail", future.channel());
+ LOG.warn("Channel {} closed: fail", channel);