return createClient(address, retryTimer, connectTimeout, (ch, promise) -> {
ch.pipeline().addLast(this.factory.getDecoders());
ch.pipeline().addLast("negotiator", this.negotiatorFactory.getSessionNegotiator(
- () -> listenerFactory,
- ch,
- promise));
+ () -> listenerFactory, ch, promise));
ch.pipeline().addLast(this.factory.getEncoders());
});
}
}
}
-}
\ No newline at end of file
+}