@@ -122,6 +122,14 @@ func (h *Hub) Subscribe(channel *regexp.Regexp, cmd string, backFunc SubscribeBa
return
}
+// 遍历频道列表
+func (h *Hub) ConnectRange(fn func(line *Line) bool) {
+ h.connects.Range(func(key, _ any) bool {
+ line := key.(*Line)
+ return fn(line)
+ })
+}
+
// 获取当前在线的数量
func (h *Hub) ConnectNum() int {
var count int
