Remove parameters on HandshakeResponseHandler
This is a followup to That commit removed the channel type
parameter from TcpTransport. This commit removes the parameter from the
handshake response handler.
@@ -278,13 +278,13 @@ public abstract class TcpTransport extends AbstractLifecycleComponent implements
this.transportService = service;
}
- private static class HandshakeResponseHandler<Channel> implements TransportResponseHandler<VersionHandshakeResponse> {
+ private static class HandshakeResponseHandler implements TransportResponseHandler<VersionHandshakeResponse> {
final AtomicReference<Version> versionRef = new AtomicReference<>();
final CountDownLatch latch = new CountDownLatch(1);
final AtomicReference<Exception> exceptionRef = new AtomicReference<>();
- final Channel channel;
+ final TcpChannel channel;
- HandshakeResponseHandler(Channel channel) {
+ HandshakeResponseHandler(TcpChannel channel) {
this.channel = channel;
}
