From 757d50d1dd293c8082d76114393a49e39735529c Mon Sep 17 00:00:00 2001
From: Mikhail Mitrofanov <mmm606@inbox.ru>
Date: Sat, 24 May 2025 23:28:32 +0300
Subject: [PATCH] Useless ping pong in recovery removed

---
 mROA/Implementation/Attributes/UntrustedAttribute.cs |  5 +++++
 mROA/Implementation/ChannelInteractionModule.cs      | 12 ++++--------
 mROA/mROA.csproj                                     |  6 +++---
 3 files changed, 12 insertions(+), 11 deletions(-)

diff --git a/mROA/Implementation/Attributes/UntrustedAttribute.cs b/mROA/Implementation/Attributes/UntrustedAttribute.cs
index 2441590..244c908 100644
--- a/mROA/Implementation/Attributes/UntrustedAttribute.cs
+++ b/mROA/Implementation/Attributes/UntrustedAttribute.cs
@@ -4,5 +4,10 @@ namespace mROA.Implementation.Attributes
 {
     public class UntrustedAttribute : Attribute
     {
+        public bool UseAwait { get; private set; }
+        public UntrustedAttribute(bool useAwait = true)
+        {
+            UseAwait = useAwait;
+        }
     }
 }
\ No newline at end of file
diff --git a/mROA/Implementation/ChannelInteractionModule.cs b/mROA/Implementation/ChannelInteractionModule.cs
index fcec7bd..c99284d 100644
--- a/mROA/Implementation/ChannelInteractionModule.cs
+++ b/mROA/Implementation/ChannelInteractionModule.cs
@@ -28,10 +28,10 @@ namespace mROA.Implementation
                 SingleWriter = false,
             });
             _receiveReader = ReceiveChanel.Reader;
-            _outputTrustedChannel = Channel.CreateBounded<NetworkMessageHeader>(new BoundedChannelOptions(1)
+            _outputTrustedChannel = Channel.CreateUnbounded<NetworkMessageHeader>(new UnboundedChannelOptions
             {
                 SingleReader = true,
-                SingleWriter = true,
+                SingleWriter = true
             });
             _trustedWriter = _outputTrustedChannel.Writer;
             _outputUntrustedChannel = Channel.CreateUnbounded<NetworkMessageHeader>(new UnboundedChannelOptions
@@ -49,7 +49,7 @@ namespace mROA.Implementation
 
         public ChannelReader<NetworkMessageHeader> TrustedPostChanel => _outputTrustedChannel.Reader;
         public ChannelReader<NetworkMessageHeader> UntrustedPostChanel => _outputUntrustedChannel.Reader;
-        public Func<bool> IsConnected { get; set; } = () => false; 
+        public Func<bool> IsConnected { get; set; } = () => false;
 
         public void Inject<T>(T dependency)
         {
@@ -121,13 +121,9 @@ namespace mROA.Implementation
             {
                 await PostMessageAsync(
                     new NetworkMessageHeader(_serialization!, new ClientRecovery(Math.Abs(ConnectionId)), _context));
-                await ReceiveChanel.Reader.ReadAsync();
-            }
-            else
-            {
-                await _trustedWriter.WriteAsync(new NetworkMessageHeader());
             }
 
+
             _reconnection.TrySetResult(Stream.Null);
             _isConnected = true;
             _reconnection = new TaskCompletionSource<Stream>();
diff --git a/mROA/mROA.csproj b/mROA/mROA.csproj
index 6c53c78..c5291f0 100644
--- a/mROA/mROA.csproj
+++ b/mROA/mROA.csproj
@@ -4,7 +4,7 @@
         <TargetFramework>netstandard2.1</TargetFramework>
         <Nullable>enable</Nullable>
         <Title>mROA</Title>
-        <Version>2.0.1</Version>
+        <Version>2.0.2</Version>
         <Authors>YaslePoy</Authors>
         <Description>Fast and easy RPC with contex</Description>
         <RepositoryUrl>https://github.com/YaslePoy/mROA</RepositoryUrl>
@@ -25,8 +25,8 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="System.Text.Json" Version="9.0.2"/>
-        <PackageReference Include="System.Threading.Channels" Version="9.0.4" />
+        <PackageReference Include="System.Text.Json" Version="9.0.5" />
+        <PackageReference Include="System.Threading.Channels" Version="9.0.5" />
     </ItemGroup>
 
 </Project>