Clears the acknowledgement handlers upon disconnection, since the client will never receive an acknowledgement from the server.
()
| 290 | * the server. |
| 291 | */ |
| 292 | private void clearAcks() { |
| 293 | for (Ack ack : this.acks.values()) { |
| 294 | if (ack instanceof AckWithTimeout) { |
| 295 | ((AckWithTimeout) ack).onTimeout(); |
| 296 | } |
| 297 | // note: basic Ack objects have no way to report an error, so they are simply ignored here |
| 298 | } |
| 299 | this.acks.clear(); |
| 300 | } |
| 301 | |
| 302 | private void onpacket(Packet<?> packet) { |
| 303 | if (!this.nsp.equals(packet.nsp)) return; |