MemoryOwner copy buffer

NetX/NetX.csproj

@@ -7,7 +7,7 @@
         <PackageProjectUrl>https://github.com/project-nevareth/NetX</PackageProjectUrl>
         <RepositoryType>git</RepositoryType>
         <PublishRepositoryUrl>true</PublishRepositoryUrl>
-        <Version>2.2.2</Version>
+        <Version>2.2.3</Version>
         <IncludeSymbols>true</IncludeSymbols>
         <SymbolPackageFormat>snupkg</SymbolPackageFormat>
     </PropertyGroup>

NetX/NetXConnection.cs

@@ -480,7 +480,10 @@ private bool TryGetReceivedMessage(
             var next = buffer.GetPosition(size);
             buffer = buffer.Slice(next);
 
-            netXMessage = new NetXMessage(messageId, _options.CopyBuffer ? messageBuffer.ToArray() : messageBuffer);
+            var messageMemory = MemoryOwner<byte>.Allocate(messageBuffer.Length);
+            messageBuffer.CopyTo(messageMemory.Memory);
+
+            netXMessage = new NetXMessage(messageId, messageMemory);
 
             return true;
         }

NetX/NetXMessage.cs

@@ -1,16 +1,25 @@
 using System;
+using System.Buffers;
+using CommunityToolkit.HighPerformance.Buffers;
 
 namespace NetX
 {
-    public readonly struct NetXMessage
+    public readonly struct NetXMessage : IDisposable
     {
         public Guid Id { get; }
-        public ReadOnlyMemory<byte> Buffer { get; }
+        public ReadOnlyMemory<byte> Buffer => _memoryOwner.Memory;
 
-        public NetXMessage(Guid id, ReadOnlyMemory<byte> buffer)
+        private readonly MemoryOwner<byte> _memoryOwner;
+
+        public NetXMessage(Guid id, MemoryOwner<byte> memoryOwner)
         {
             Id = id;
-            Buffer = buffer;
+            _memoryOwner = memoryOwner;
+        }
+
+        public void Dispose()
+        {
+            _memoryOwner.Dispose();
         }
     }
 }

samples/ServerClientSample/Program.cs

@@ -7,7 +7,6 @@
 using NetX;
 using NetX.Options;
 using Serilog;
-using static System.Net.Mime.MediaTypeNames;
 
 namespace ServerClientSample
 {