package tinymq import ( "regexp" "strings" ) // 正则频道过滤器 func RegChannelFilter(channel *regexp.Regexp) FilterFunc { return func(conn *Line) (ok bool) { return channel.MatchString(conn.channel) } } // 字符串频道过滤器 func StrChannelFilter(channel string) FilterFunc { return func(conn *Line) (ok bool) { return strings.Contains(conn.channel, channel) } }