tinymq/filter.go

package tinymq

import "regexp"

// 正则频道过滤器
func RegChannelFilter(channel *regexp.Regexp) FilterFunc {
	return func(conn *Line) (ok bool) {
		return channel.MatchString(conn.channel)
	}
}

// 字符串频道过滤器
func StrChannelFilter(channel string) FilterFunc {
	c := regexp.MustCompile(channel)
	return func(conn *Line) (ok bool) {
		return c.MatchString(conn.channel)
	}
}