Skip to content

Commit 20ade4e

Browse files
committed
[删除]1. 删除不必要的编码器传递
1 parent c00a66e commit 20ade4e

File tree

2 files changed

+3
-12
lines changed

2 files changed

+3
-12
lines changed

GameFrameX.NetWork/BaseNetWorkChannel.cs

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -13,11 +13,6 @@ namespace GameFrameX.NetWork;
1313
/// </summary>
1414
public class BaseNetWorkChannel : INetWorkChannel
1515
{
16-
/// <summary>
17-
/// 消息编码器
18-
/// </summary>
19-
private readonly IMessageEncoderHandler _messageEncoder;
20-
2116
/// <summary>
2217
/// WebSocket会话
2318
/// </summary>
@@ -33,17 +28,14 @@ public class BaseNetWorkChannel : INetWorkChannel
3328
/// </summary>
3429
/// <param name="session"></param>
3530
/// <param name="setting"></param>
36-
/// <param name="messageEncoder"></param>
3731
/// <param name="rpcSession"></param>
3832
/// <param name="isWebSocket"></param>
39-
public BaseNetWorkChannel(IGameAppSession session, AppSetting setting, IMessageEncoderHandler messageEncoder, IRpcSession rpcSession, bool isWebSocket)
33+
public BaseNetWorkChannel(IGameAppSession session, AppSetting setting, IRpcSession rpcSession, bool isWebSocket)
4034
{
4135
setting.CheckNotNull(nameof(setting));
42-
messageEncoder.CheckNotNull(nameof(messageEncoder));
4336
GameAppSession = session;
4437
IsWebSocket = isWebSocket;
4538
Setting = setting;
46-
_messageEncoder = messageEncoder;
4739
RpcSession = rpcSession;
4840
if (isWebSocket)
4941
{
@@ -86,7 +78,7 @@ public virtual async Task WriteAsync(INetworkMessage messageObject, int errorCod
8678
responseMessage.ErrorCode = errorCode;
8779
}
8880

89-
var messageData = _messageEncoder.Handler(messageObject);
81+
var messageData = MessageHelper.EncoderHandler.Handler(messageObject);
9082
if (Setting.IsDebug && Setting.IsDebugSend)
9183
{
9284
// 判断是否是心跳消息

GameFrameX.NetWork/DefaultNetWorkChannel.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,9 @@ public class DefaultNetWorkChannel : BaseNetWorkChannel
1414
/// </summary>
1515
/// <param name="session"></param>
1616
/// <param name="setting"></param>
17-
/// <param name="messageEncoder"></param>
1817
/// <param name="rpcSession"></param>
1918
/// <param name="isWebSocket"></param>
20-
public DefaultNetWorkChannel(IGameAppSession session, AppSetting setting, IMessageEncoderHandler messageEncoder, IRpcSession rpcSession = null, bool isWebSocket = false) : base(session, setting, messageEncoder, rpcSession, isWebSocket)
19+
public DefaultNetWorkChannel(IGameAppSession session, AppSetting setting, IRpcSession rpcSession = null, bool isWebSocket = false) : base(session, setting, rpcSession, isWebSocket)
2120
{
2221
}
2322
}

0 commit comments

Comments
 (0)