test: Fix flicker in SpanStreamingServiceTests (#2167)

newrelic · Jan 3, 2024 · 77d7e5c · 77d7e5c
1 parent f6c9a9f
commit 77d7e5c
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/tests/Agent/UnitTests/Core.UnitTest/Spans/SpanStreamingServiceTests.cs b/tests/Agent/UnitTests/Core.UnitTest/Spans/SpanStreamingServiceTests.cs
@@ -650,13 +650,13 @@ public void DelayCallingRecordSpanAfterAnErrorStreamingASpan()
         }
 
         [Test]
-        public void MultpleConsumersItemsSentOnlyOnce()
+        public void MultipleConsumersItemsSentOnlyOnce()
         {
             Mock.Arrange(() => _currentConfiguration.InfiniteTracingBatchSizeSpans).Returns(4);
             Mock.Arrange(() => _currentConfiguration.InfiniteTracingTraceCountConsumers).Returns(3);
             _streamingSvc = GetService(_delayer, _grpcWrapper, _configSvc, _agentHealthReporter);
 
-            var actualItems = new List<TRequest>();
+            var actualItems = new ConcurrentBag<TRequest>();
             var requestItems = new ConcurrentBag<TRequest>();
             for (var i = 0; i < 100; i++)
             {
@@ -668,7 +668,8 @@ public void MultpleConsumersItemsSentOnlyOnce()
             _grpcWrapper.WithTrySendDataImpl = (stream, requestBatch, timeout, token) =>
                 {
                     var requests = GetBatchItems(requestBatch);
-                    actualItems.AddRange(requests);
+                    foreach (var streamingModel in requests)
+                        actualItems.Add(streamingModel);
 
                     return true;
                 };