release lock before returning buffers

Signed-off-by: Caleb Lloyd <caleb@synadia.com>
nats-io · Feb 8, 2024 · 3e24a07 · 3e24a07
1 parent 3f8cb7b
commit 3e24a07
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/NATS.Client.Core/Commands/CommandWriter.cs b/src/NATS.Client.Core/Commands/CommandWriter.cs
@@ -328,6 +328,8 @@ public ValueTask PublishAsync<T>(string subject, T? value, NatsHeaders? headers,
         }
         finally
         {
+            _semLock.Release();
+
             payloadBuffer.Reset();
             _pool.Return(payloadBuffer);
 
@@ -336,8 +338,6 @@ public ValueTask PublishAsync<T>(string subject, T? value, NatsHeaders? headers,
                 headersBuffer.Reset();
                 _pool.Return(headersBuffer);
             }
-
-            _semLock.Release();
         }
 
         return ValueTask.CompletedTask;