Source
void removeSubscription(ReqSubscribeController controller) { String path = controller.node.remotePath; if (subscriptions.containsKey(path)) { toRemove[subscriptions[path].sid] = subscriptions[path]; prepareSending(); } else if (subscriptionIds.containsKey(controller.sid)) { logger.severe( 'unexpected remoteSubscription in the requester, sid: ${controller .sid}'); } }