mm_rpc_sever

type Asker struct {
	IsMult        bool
	SessionId     string
	Ch            chan model.MsgReq
	MAskServer    grpc.ServerStreamingServer[pb.MRpcMessageAck]
	MStreamServer grpc.BidiStreamingServer[pb.MRpcMessage, pb.MRpcMessageAck]
}

type IServerMsgHandle interface {
	/**
	*  客户端相应请求
	 */
	HandleRequest(sessionId string, msgId int32, data []byte) (int32, []byte, error)

	/**
	* 客户端单请求，多次Resp
	 */
	RequestMultResp(sessionId string, msgId int32, data []byte, ask *Asker) error

	/**
	 * 客户端多请求，单次Resp
	 */
	MultiRequest(ch chan model.MsgReq) (int32, []byte, error)

	/**
	* 双向流
	 */
	DuplexStream(ch chan model.MsgReq, ask *Asker) error
}

type MRpcServer struct {
	pb.UnimplementedMRpcServiceServer

	Context    context.Context
	CancelFunc context.CancelFunc
	// contains filtered or unexported fields
}