onDataFromLooseDirectSubscription method

void onDataFromLooseDirectSubscription(
  1. DataPackage package
)

Implementation

void onDataFromLooseDirectSubscription(DataPackage package)
{
    LooseDirectChannelSubscription subscription = package.controlVal.looseDirectSubscription;
    String id = _makeLooseDirectSubscriptionId(subscription);

    if(!_looseDirectSubscriptionCallbacks.containsKey(id))
    {
      Logger.logError("Failed to forward data from loose direct connection. "
      + "Entity $entityName does not have DataReceiver for subscription \"$id\"");
      return;
    }

    _looseDirectSubscriptionCallbacks[id]!.onData(package);
}