removeSubscription method

void removeSubscription(
  1. ReqSubscribeController controller
)

Implementation

void removeSubscription(ReqSubscribeController controller) {
  var 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}',
    );
  }
}