func (manager *MemorySubscriptions) FindByKind(kind string) (*Subscription, bool) {
    manager.mutex.RLock()
    defer manager.mutex.RUnlock()

    for _, subscription := range manager.byIdentifier {