tryGetExistingSubscription method

Subscription? tryGetExistingSubscription(
  1. String topic
)

Gets a view on the existing observable, if the subscription already exists.

Implementation

Subscription? tryGetExistingSubscription(String topic) {
  final retSub = subscriptions[topic];
  if (retSub == null) {
    // Search the pending subscriptions
    for (final sub in pendingSubscriptions.values) {
      if (sub.topic.rawTopic == topic) {
        return sub;
      }
    }
  }
  return retSub;
}