+func (r *Registry) GetSubscriptionFirstMatch(ids []uint16) (*Subscription, error) {
+ r.mutex.Lock()
+ defer r.mutex.Unlock()
+ for _, id := range ids {
+ if _, ok := r.register[id]; ok {
+ return r.register[id], nil
+ }
+ }
+ return nil, fmt.Errorf("No valid subscription found with ids %v", ids)
+}
+