From bee684bc582f8cb48503442986f57d92bca5e6a2 Mon Sep 17 00:00:00 2001 From: Nikita Date: Sat, 7 Dec 2013 17:37:45 +0400 Subject: [PATCH] XHR-pooling regression fixed (again). http://stackoverflow.com/questions/20051846 --- .../corundumstudio/socketio/transport/XHRPollingClient.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/corundumstudio/socketio/transport/XHRPollingClient.java b/src/main/java/com/corundumstudio/socketio/transport/XHRPollingClient.java index 108e43d..cec771e 100644 --- a/src/main/java/com/corundumstudio/socketio/transport/XHRPollingClient.java +++ b/src/main/java/com/corundumstudio/socketio/transport/XHRPollingClient.java @@ -50,7 +50,8 @@ public class XHRPollingClient extends MainBaseClient { } public ChannelFuture send(final Packet packet) { - ChannelPromise promise = getChannel().newPromise(); + Channel currChannel = getChannel(); + ChannelPromise promise = currChannel.newPromise(); promise.addListener(new GenericFutureListener>() { @Override public void operationComplete(Future future) throws Exception { @@ -62,7 +63,7 @@ public class XHRPollingClient extends MainBaseClient { } }); - return getChannel().write(new XHRPacketMessage(getSessionId(), origin, packet), promise); + return currChannel.write(new XHRPacketMessage(getSessionId(), origin, packet), promise); } }