Added inlining

nats-io · Jan 29, 2024 · 2404ff3 · 2404ff3
1 parent 3efe37c
commit 2404ff3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/NATS.Client.Core/Commands/CommandWriter.cs b/src/NATS.Client.Core/Commands/CommandWriter.cs
@@ -242,6 +242,7 @@ public async ValueTask UnsubscribeAsync(int sid, int? maxMsgs, CancellationToken
     [MethodImpl(MethodImplOptions.NoInlining)]
     private static void ThrowOnDisconnected() => throw new NatsException("Connection hasn't been established yet.");
 
+    [MethodImpl(MethodImplOptions.AggressiveInlining)]
     private PipeWriter GetWriter()
     {
         lock (_lock)
@@ -287,12 +288,14 @@ private async ValueTask PublishLockedAsync(string subject, string? replyTo,  Nat
         }
     }
 
+    [MethodImpl(MethodImplOptions.AggressiveInlining)]
     private ValueTask<int> UnLockAsync(CancellationToken cancellationToken)
     {
         Interlocked.Decrement(ref _counter.PendingMessages);
         return _channelLock.Reader.ReadAsync(cancellationToken);
     }
 
+    [MethodImpl(MethodImplOptions.AggressiveInlining)]
     private ValueTask LockAsync(CancellationToken cancellationToken)
     {
         Interlocked.Increment(ref _counter.PendingMessages);