package netService

import "gitee.com/ling-bin/netwebSocket/netInterface"

//客户端请求内容
type ReceiveTask struct {
	conn    netInterface.IConnection //已经和客户端建立好的 链接
	data    []byte                   //客户端请求的数据
	msgType int                      //消息类型
	OnReceive func(int,[]byte)
}

//获取连接id
func (r *ReceiveTask) GetTaskId() uint64 {
	return r.conn.GetConnId()
}

//处理数据
func (r *ReceiveTask) RunTask() int {
	r.OnReceive(r.msgType, r.data)
	return 0
}

//超时回调
func (r *ReceiveTask) CallOutTime() {
	r.conn.CallLogHandle(netInterface.Error, "[webSocket]连接处理超时", "远程地址=>", r.conn.GetRemoteAddr(), " 任务ID=> ", r.GetTaskId())
}