tryGetExistingSubscription method
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;
}