|
|
@@ -389,6 +389,8 @@ func (h *Hub) requestFromNet(request *RequestData) {
|
|
|
for i := len(subs) - 1; i >= 0; i-- {
|
|
|
rg := subs[i]
|
|
|
if rg.Filter(request.conn) {
|
|
|
+ // 加入filter是为了能更好看到是哪个过滤器匹配的
|
|
|
+ request.filter = rg.Filter
|
|
|
state, data := rg.BackFunc(request)
|
|
|
// NEXT_SUBSCRIBE 表示当前的函数没有处理完成,还需要下个注册函数处理
|
|
|
if state == config.NEXT_SUBSCRIBE {
|