method initStorage

Source

void initStorage(ISubscriptionResponderStorage s, List<ISubscriptionNodeStorage> nodes) {
  if (storage != null) {
    storage.destroy();
  }
  storage = s;
  if (storage != null && nodes != null) {
    for (ISubscriptionNodeStorage node in nodes) {
      var values = node.getLoadedValues();
      LocalNode localnode = nodeProvider.getOrCreateNode(node.path, false);
      RespSubscribeController controller = _subscription.add(
        node.path,
        localnode,
        -1,
        node.qos
      );
      if (values.isNotEmpty) {
        controller.resetCache(values);
      }
    }
  }
}