doen't return
This commit is contained in:
@@ -103,12 +103,11 @@ public abstract class Socket extends Emitter {
|
|||||||
Socket.sockets.evs.emit("add", this);
|
Socket.sockets.evs.emit("add", this);
|
||||||
}
|
}
|
||||||
|
|
||||||
public Socket open() {
|
public void open() {
|
||||||
this.readyState = "opening";
|
this.readyState = "opening";
|
||||||
Transport transport = this.createTransport(this.transports.get(0));
|
Transport transport = this.createTransport(this.transports.get(0));
|
||||||
this.setTransport(transport);
|
this.setTransport(transport);
|
||||||
transport.open();
|
transport.open();
|
||||||
return this;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private Transport createTransport(String name) {
|
private Transport createTransport(String name) {
|
||||||
|
|||||||
@@ -98,7 +98,8 @@ public class SocketTest {
|
|||||||
System.out.println("onclose:");
|
System.out.println("onclose:");
|
||||||
events.offer("onclose");
|
events.offer("onclose");
|
||||||
}
|
}
|
||||||
}.open();
|
};
|
||||||
|
socket.open();
|
||||||
|
|
||||||
assertThat(events.take(), is("onopen"));
|
assertThat(events.take(), is("onopen"));
|
||||||
socket.close();
|
socket.close();
|
||||||
|
|||||||
Reference in New Issue
Block a user