Source
void remove(int sid) { if (subsriptionids[sid] != null) { RespSubscribeController controller = subsriptionids[sid]; subsriptionids[sid].destroy(); subsriptionids.remove(sid); subscriptions.remove(controller.node.path); if (responder._traceCallbacks != null) { ResponseTrace update = new ResponseTrace( controller.node.path, 'subscribe', 0, '-'); for (ResponseTraceCallback callback in responder._traceCallbacks) { callback(update); } } if (subsriptionids.isEmpty) { _waitingAckCount = 0; } } }