Source
void addSubscription(ReqSubscribeController controller, int level) {
String path = controller.node.remotePath;
subscriptions[path] = controller;
subscriptionIds[controller.sid] = controller;
prepareSending();
_changedPaths.add(path);
}