From 3144dc60ec2bd9637793f9524376fbc031cafca8 Mon Sep 17 00:00:00 2001 From: Naoyuki Kanezawa Date: Wed, 22 Apr 2015 03:06:30 +0900 Subject: [PATCH] trigger transport event upon its creation --- .../com/github/nkzawa/engineio/client/Socket.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/github/nkzawa/engineio/client/Socket.java b/src/main/java/com/github/nkzawa/engineio/client/Socket.java index ac37fef..4da61a6 100644 --- a/src/main/java/com/github/nkzawa/engineio/client/Socket.java +++ b/src/main/java/com/github/nkzawa/engineio/client/Socket.java @@ -255,13 +255,18 @@ public class Socket extends Emitter { opts.policyPort = this.policyPort; opts.socket = this; + Transport transport; if (WebSocket.NAME.equals(name)) { - return new WebSocket(opts); + transport = new WebSocket(opts); } else if (Polling.NAME.equals(name)) { - return new PollingXHR(opts); + transport = new PollingXHR(opts); + } else { + throw new RuntimeException(); } - throw new RuntimeException(); + this.emit(EVENT_TRANSPORT, transport); + + return transport; } private void setTransport(Transport transport) { @@ -275,8 +280,6 @@ public class Socket extends Emitter { this.transport = transport; - self.emit(EVENT_TRANSPORT, transport); - transport.on(Transport.EVENT_DRAIN, new Listener() { @Override public void call(Object... args) {