Fixed re-init ports

HakanL · May 29, 2024 · 8686a0c · 8686a0c
1 parent 625082a
commit 8686a0c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/Haukcode.sACN/Haukcode.sACN.csproj b/src/Haukcode.sACN/Haukcode.sACN.csproj
@@ -35,7 +35,7 @@
   <ItemGroup>
     <PackageReference Include="Haukcode.Network" Version="1.0.10" />
     <PackageReference Include="System.Net.NetworkInformation" Version="4.3.0" />
-    <PackageReference Include="System.Reactive" Version="6.0.0" />
+    <PackageReference Include="System.Reactive" Version="6.0.1" />
   </ItemGroup>
 
 </Project>
diff --git a/src/Haukcode.sACN/SACNClient.cs b/src/Haukcode.sACN/SACNClient.cs
@@ -275,10 +275,12 @@ private async Task Sender()
         {
             while (!this.shutdownCTS.IsCancellationRequested)
             {
-                var sendData = this.sendQueue.Take(this.shutdownCTS.Token);
+                SendData sendData = null;
 
                 try
                 {
+                    sendData = this.sendQueue.Take(this.shutdownCTS.Token);
+
                     if (sendData.AgeMS > 100)
                     {
                         // Old, discard
@@ -316,7 +318,7 @@ private async Task Sender()
                 finally
                 {
                     // Return to pool
-                    sendData.Data.Dispose();
+                    sendData?.Data?.Dispose();
                 }
             }
         }