refactor

jonfortescue · Sep 24, 2021 · 46ca3ae · 46ca3ae
1 parent d3c09d0
commit 46ca3ae
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/Microsoft.DotNet.Interactive/Connection/MultiplexingKernelCommandAndEventReceiver.cs b/src/Microsoft.DotNet.Interactive/Connection/MultiplexingKernelCommandAndEventReceiver.cs
@@ -57,13 +57,14 @@ public async IAsyncEnumerable<CommandOrEvent> CommandsAndEventsAsync([Enumerator
 
             await foreach (var commandOrEvent in _source.CommandsAndEventsAsync(cancellationToken))
             {
-                var sources = Array.Empty<BlockingCollection<CommandOrEvent>>();
+                BlockingCollection<CommandOrEvent>[] sources;
 
                 lock (_children)
                 {
                     sources = _children.Select(c => c.LocalStorage).ToArray();
                 }
-                if (_children.Count > 0)
+
+                if (sources.Length > 0)
                 {
                     foreach (var destination in sources)
                     {