File tree Expand file tree Collapse file tree 1 file changed +12
-8
lines changed
Expand file tree Collapse file tree 1 file changed +12
-8
lines changed Original file line number Diff line number Diff line change @@ -47,37 +47,41 @@ public void Dispose()
4747 }
4848
4949 /// <summary>
50- /// RPC回复
50+ /// 处理RPC回复消息。
51+ /// 此方法用于处理接收到的RPC回复消息,并触发相应的结束处理程序。
5152 /// </summary>
52- /// <param name="message">消息对象 </param>
53- /// <returns></returns>
53+ /// <param name="message">要处理的消息对象,必须实现IResponseMessage接口。 </param>
54+ /// <returns>如果成功处理回复消息,则返回true;否则返回false。 </returns>
5455 public bool Reply ( MessageObject message )
5556 {
5657 if ( message . GetType ( ) . IsImplWithInterface ( typeof ( IResponseMessage ) ) )
5758 {
5859 if ( m_HandlingObjects . TryRemove ( message . UniqueId , out var messageActorObject ) )
5960 {
60- messageActorObject . Reply ( message as IResponseMessage ) ;
6161 try
6262 {
63+ messageActorObject . Reply ( message as IResponseMessage ) ;
6364 m_RpcEndHandler ? . Invoke ( this , message ) ;
64- return true ;
6565 }
6666 catch ( Exception e )
6767 {
6868 Log . Fatal ( e ) ;
6969 }
70+
71+ return true ;
7072 }
7173 }
7274
7375 return false ;
7476 }
7577
7678 /// <summary>
77- /// 调用并等待返回结果。可能引发超时异常
79+ /// 调用RPC并等待返回结果。
80+ /// 此方法会发送一个请求消息并返回一个任务,任务将在收到响应时完成。
81+ /// 可能会引发超时异常。
7882 /// </summary>
79- /// <param name="messageObject">消息对象 </param>
80- /// <returns></returns>
83+ /// <param name="messageObject">要发送的消息对象,必须实现IRequestMessage接口。 </param>
84+ /// <returns>返回一个任务,该任务在收到响应时完成,并返回IResponseMessage。 </returns>
8185 public Task < IResponseMessage > Call ( MessageObject messageObject )
8286 {
8387 if ( m_HandlingObjects . TryGetValue ( messageObject . UniqueId , out var messageActorObject ) )
You can’t perform that action at this time.
0 commit comments