- tcpConnectFuture.addListener(new GenericFutureListener<Future<? super Void>>() {
- @Override
- public void operationComplete(final Future<? super Void> future) throws Exception {
- if(future.isSuccess()) {
- //complete connection promise with netconf negotiation future
- negotiationFuture.addListener(negotiationFutureListener);
- } else {
- connectPromise.setFailure(future.cause());
- }
+ tcpConnectFuture.addListener(future -> {
+ if (future.isSuccess()) {
+ //complete connection promise with netconf negotiation future
+ negotiationFuture.addListener(negotiationFutureListener);
+ } else {
+ channelPromise.setFailure(future.cause());