Buffer position

nats-io · Feb 2, 2024 · 6334b57 · 6334b57
1 parent d3c0288
commit 6334b57
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/src/NATS.Client.Core/Commands/CommandWriter.cs b/src/NATS.Client.Core/Commands/CommandWriter.cs
@@ -322,19 +322,18 @@ private static async Task ReaderLoopAsync(ILogger<CommandWriter> logger, ISocket
 
                 var buffer = result.Buffer;
                 var consumed = buffer.Start;
-
-                buffer = buffer.Slice(examinedOffset);
-                var examined = buffer.Start;
+                var examined = buffer.GetPosition(examinedOffset);
 
                 try
                 {
                     if (!buffer.IsEmpty)
                     {
-                        var bufferLength = (int)buffer.Length;
+                        var readBuffer = buffer.Slice(examinedOffset);
+                        var bufferLength = (int)readBuffer.Length;
 
                         var bytes = ArrayPool<byte>.Shared.Rent(bufferLength);
-                        buffer.CopyTo(bytes);
-                        var memory = bytes.AsMemory(0, (int)buffer.Length);
+                        readBuffer.CopyTo(bytes);
+                        var memory = bytes.AsMemory(0, bufferLength);
 
                         try
                         {