If there is no destination (i.e. CommandType.Done), just skip it.

zeromq · May 16, 2024 · 7f9fb67 · 7f9fb67
1 parent a7d8429
commit 7f9fb67
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 7 deletions.
diff --git a/src/NetMQ/Core/IOThread.cs b/src/NetMQ/Core/IOThread.cs
@@ -91,8 +91,7 @@ public void Ready()
             // Process all available commands.
             while (m_mailbox.TryRecv(out Command command))
             {
-                Assumes.NotNull(command.Destination);
-                command.Destination.ProcessCommand(command);
+                command.Destination?.ProcessCommand(command);
             }
         }
 

diff --git a/src/NetMQ/Core/Reaper.cs b/src/NetMQ/Core/Reaper.cs
@@ -126,10 +126,8 @@ public void InEvent()
                 if (!m_mailbox.TryRecv(0, out Command command))
                     break;
 
-                Assumes.NotNull(command.Destination);
-
                 // Process the command.
-                command.Destination.ProcessCommand(command);
+                command.Destination?.ProcessCommand(command);
             }
         }
 

diff --git a/src/NetMQ/Core/SocketBase.cs b/src/NetMQ/Core/SocketBase.cs
@@ -1261,8 +1261,7 @@ private void ProcessCommands(int timeout, bool throttle, CancellationToken cance
             // Process all the commands available at the moment.
             while (found)
             {
-                Assumes.NotNull(command.Destination);
-                command.Destination.ProcessCommand(command);
+                command.Destination?.ProcessCommand(command);
                 found = m_mailbox.TryRecv(0, out command);
             }