better perf in HandleStashedInbound (#7409)

* better perf in HandleStashedInbound * Update EndpointManager.cs
akkadotnet · Dec 18, 2024 · 21ee0c4 · 21ee0c4
1 parent 55644b1
commit 21ee0c4
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/src/core/Akka.Remote/EndpointManager.cs b/src/core/Akka.Remote/EndpointManager.cs
@@ -515,10 +515,9 @@ private ICancelable PruneTimerCancelleable
 
         private void HandleStashedInbound(IActorRef endpoint, bool writerIsIdle)
         {
-            var stashed = _stashedInbound.GetOrElse(endpoint, new List<InboundAssociation>());
-            _stashedInbound.Remove(endpoint);
-            foreach (var ia in stashed)
-                HandleInboundAssociation(ia, writerIsIdle);
+            if (_stashedInbound.Remove(endpoint, out var value))
+                foreach (var ia in value)
+                    HandleInboundAssociation(ia, writerIsIdle);
         }
 
         private void KeepQuarantinedOr(Address remoteAddress, Action body)