|
|
@@ -161,6 +161,16 @@ func (h *Hub) Subscribe(filter FilterFunc, cmd string, backFunc SubscribeBackFun
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+// 注册多个频道
|
|
|
+func (h *Hub) Subscribes(filters []FilterFunc, cmd string, backFunc SubscribeBackFunc) (err error) {
|
|
|
+ for _, filter := range filters {
|
|
|
+ if err := h.Subscribe(filter, cmd, backFunc); err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
// 遍历频道列表
|
|
|
// 如果 fn 返回 false，则 range 停止迭代
|
|
|
func (h *Hub) ConnectRange(fn func(id int, line *Line) bool) {
|
