| 75 | } |
| 76 | |
| 77 | private void subEvents() { |
| 78 | if (this.subs != null) return; |
| 79 | |
| 80 | final Manager io = Socket.this.io; |
| 81 | Socket.this.subs = new LinkedList<On.Handle>() {{ |
| 82 | add(On.on(io, Manager.EVENT_OPEN, new Listener() { |
| 83 | @Override |
| 84 | public void call(Object... args) { |
| 85 | Socket.this.onopen(); |
| 86 | } |
| 87 | })); |
| 88 | add(On.on(io, Manager.EVENT_PACKET, new Listener() { |
| 89 | @Override |
| 90 | public void call(Object... args) { |
| 91 | Socket.this.onpacket((Packet<?>) args[0]); |
| 92 | } |
| 93 | })); |
| 94 | add(On.on(io, Manager.EVENT_ERROR, new Listener() { |
| 95 | @Override |
| 96 | public void call(Object... args) { |
| 97 | if (!Socket.this.connected) { |
| 98 | Socket.super.emit(EVENT_CONNECT_ERROR, args[0]); |
| 99 | } |
| 100 | } |
| 101 | })); |
| 102 | add(On.on(io, Manager.EVENT_CLOSE, new Listener() { |
| 103 | @Override |
| 104 | public void call(Object... args) { |
| 105 | Socket.this.onclose(args.length > 0 ? (String) args[0] : null); |
| 106 | } |
| 107 | })); |
| 108 | }}; |
| 109 | } |
| 110 | |
| 111 | public boolean isActive() { |
| 112 | return this.subs != null; |