diff --git a/src/NATS.Client.Core/Commands/CommandWriter.cs b/src/NATS.Client.Core/Commands/CommandWriter.cs
index 536775705..91360f577 100644
--- a/src/NATS.Client.Core/Commands/CommandWriter.cs
+++ b/src/NATS.Client.Core/Commands/CommandWriter.cs
@@ -158,8 +158,13 @@ public async ValueTask DisposeAsync()
 
 #if NET8_0_OR_GREATER
         await _cts.CancelAsync().ConfigureAwait(false);
+        if (_ctsReader != null)
+        {
+            await _ctsReader.CancelAsync().ConfigureAwait(false);
+        }
 #else
         _cts.Cancel();
+        _ctsReader?.Cancel();
 #endif
 
         _channelLock.Writer.TryComplete();