fix

hub.go

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

type.go

@@ -84,14 +84,14 @@ const (
 
 // 请求数据包
 type RequestData struct {
-	Id   uint16
-	Cmd  string
-	Data []byte
+	Id     uint16
+	Cmd    string
+	Data   []byte
+	Filter FilterFunc // 过滤器
 
 	timeout  int                // 超时时间，单位为毫秒
 	backchan chan *ResponseData // 返回数据的管道
 	conn     *Line              // 将连接传递出去是为了能够让上层找回来
-	filter   FilterFunc         // 过滤器
 }
 
 func (r *RequestData) Conn() *Line {