func (store *Store) HasStreamRule(streamID, streamRuleID string) (bool, error) {
	store.imutex.RLock()
	defer store.imutex.RUnlock()
	rules, ok := store.streamRules[streamID]
	if !ok {
		return false, nil
	}
	_, ok = rules[streamRuleID]
	return ok, nil
}
// HasStreamRule returns whether the stream rule exists.
HasStreamRule returns whether the stream rule exists.
// HasStreamRule returns whether the stream rule exists .
func (store *Store) HasStreamRule(streamID, streamRuleID string) (bool, error) {
	store.imutex.RLock()
	defer store.imutex.RUnlock()
	rules, ok := store.streamRules[streamID]
	if !ok {
		return false, nil
	}
	_, ok = rules[streamRuleID]
	return ok, nil
}
func ( store * Store ) HasStreamRule ( streamID , streamRuleID string ) ( bool , error ) { store . imutex . RLock ( ) defer store . imutex . RUnlock ( ) rules , ok := store . streamRules [ streamID ] if ! ok { return false , nil } _ , ok = rules [ streamRuleID ] return ok , nil }
HasStreamRule returns whether the stream rule exists.
HasStreamRule returns whether the stream rule exists .