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