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 f678087..c1b3616 100644 --- a/src/main/java/com/github/nkzawa/engineio/client/Socket.java +++ b/src/main/java/com/github/nkzawa/engineio/client/Socket.java @@ -103,12 +103,11 @@ public abstract class Socket extends Emitter { Socket.sockets.evs.emit("add", this); } - public Socket open() { + public void open() { this.readyState = "opening"; Transport transport = this.createTransport(this.transports.get(0)); this.setTransport(transport); transport.open(); - return this; } private Transport createTransport(String name) { diff --git a/src/test/java/com/github/nkzawa/engineio/client/SocketTest.java b/src/test/java/com/github/nkzawa/engineio/client/SocketTest.java index 4f68e4c..6a5365d 100644 --- a/src/test/java/com/github/nkzawa/engineio/client/SocketTest.java +++ b/src/test/java/com/github/nkzawa/engineio/client/SocketTest.java @@ -98,7 +98,8 @@ public class SocketTest { System.out.println("onclose:"); events.offer("onclose"); } - }.open(); + }; + socket.open(); assertThat(events.take(), is("onopen")); socket.close();