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;
}
}
}