From bd4d33670e0fa43d5b7c1cdab9b8b7a96448db30 Mon Sep 17 00:00:00 2001 From: Michael Nolan Date: Mon, 19 Jun 2023 05:03:38 -0500 Subject: [PATCH] Add Id to MessageReceived --- Tesses.RPC/Class1.cs | 6 ++++-- Tesses.RPC/Tesses.RPC.csproj | 6 +++--- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/Tesses.RPC/Class1.cs b/Tesses.RPC/Class1.cs index d115a1d..cc21dfd 100644 --- a/Tesses.RPC/Class1.cs +++ b/Tesses.RPC/Class1.cs @@ -38,12 +38,14 @@ namespace Tesses.RPC public sealed class MessageReceived { Action reply; - internal MessageReceived(T data,bool needReply,Action reply) + internal MessageReceived(T data,bool needReply,long id,Action reply) { Data = data; NeedReply = needReply; this.reply=reply; + Id = id; } + public long Id {get;private set;} public T Data {get;private set;} public bool NeedReply {get;private set;} public void Reply(TType msg) @@ -85,7 +87,7 @@ namespace Tesses.RPC if(recv!=null && msg.MessageState != MessageState.ResponseNoForget) { - MessageReceived msg0=new MessageReceived(msg.Value.ToObject(),msg.MessageState != MessageState.Forget ,(reply)=>{ + MessageReceived msg0=new MessageReceived(msg.Value.ToObject(),msg.MessageState != MessageState.Forget ,msg.Id,(reply)=>{ SendMessageResponse(reply,msg.Id); }); recv?.Invoke(msg0); diff --git a/Tesses.RPC/Tesses.RPC.csproj b/Tesses.RPC/Tesses.RPC.csproj index ad394f9..48b5173 100644 --- a/Tesses.RPC/Tesses.RPC.csproj +++ b/Tesses.RPC/Tesses.RPC.csproj @@ -10,9 +10,9 @@ Tesses.RPC Mike Nolan Tesses - 1.0.1 - 1.0.1 - 1.0.1 + 1.0.2 + 1.0.2 + 1.0.2 A simple RPC library for .NET GPL-3.0-only true