From 373356528717adb1be5bcc83fe50b56859189187 Mon Sep 17 00:00:00 2001
From: Ziya Suzen <ziya@suzen.net>
Date: Tue, 12 Aug 2025 10:32:27 +0100
Subject: [PATCH] Fix CommandWriter.cs dispose

---
 src/NATS.Client.Core/Commands/CommandWriter.cs | 5 +++++
 1 file changed, 5 insertions(+)

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();