Parker2991/MCProtocolLib
1
0
Fork 0
mirror of https://github.com/GeyserMC/MCProtocolLib.git synced 2024-12-04 21:01:02 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Sync future instead of using listener.

Browse source
This commit is contained in:
Steven Smith 2015-08-21 21:14:17 -07:00
parent 34c2a5c291
commit fa806e58fe
1 changed files with 1 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/main/java/org/spacehq/packetlib/tcp/TcpClientSession.java
View file

@ -3,7 +3,6 @@ package org.spacehq.packetlib.tcp;
import io.netty.bootstrap.Bootstrap; import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel; import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption; import io.netty.channel.ChannelOption;
import io.netty.channel.ChannelPipeline; import io.netty.channel.ChannelPipeline;
@ -89,16 +88,7 @@ public class TcpClientSession extends TcpSession {
bootstrap.remoteAddress(host, port); bootstrap.remoteAddress(host, port);
ChannelFuture future = bootstrap.connect(); ChannelFuture future = bootstrap.connect().sync();
future.addListener(new ChannelFutureListener() {
@Override
public void operationComplete(ChannelFuture future) throws Exception {
if(!future.isSuccess()) {
exceptionCaught(null, future.cause());
}
}
}).await();
if(future.isSuccess()) { if(future.isSuccess()) {
while(!isConnected()) { while(!isConnected()) {
try { try {