Kr igor/apms 1755 v3

tracer/src/Datadog.Trace/DataStreamsMonitoring/DataStreamsWriter.cs

@@ -25,9 +25,8 @@ internal class DataStreamsWriter : IDataStreamsWriter
 
     private readonly object _initLock = new();
     private readonly long _bucketDurationMs;
-    private readonly BoundedConcurrentQueue<StatsPoint> _buffer = new(queueLimit: 10_000);
-    private readonly BoundedConcurrentQueue<BacklogPoint> _backlogBuffer = new(queueLimit: 10_000);
-    private readonly TimeSpan _waitTimeSpan = TimeSpan.FromMilliseconds(10);
+    private readonly BoundedConcurrentQueue<StatsPoint> _buffer = new(queueLimit: 25_000);
+    private readonly BoundedConcurrentQueue<BacklogPoint> _backlogBuffer = new(queueLimit: 25_000);
     private readonly DataStreamsAggregator _aggregator;
     private readonly IDiscoveryService _discoveryService;
     private readonly IDataStreamsApi _api;
@@ -313,13 +312,7 @@ private async Task ProcessQueueLoopAsync()
                 continue;
             }
 
-            // The logic is copied from https://github.com/dotnet/runtime/blob/main/src/libraries/Common/tests/System/Threading/Tasks/TaskTimeoutExtensions.cs#L26
-            // and modified to avoid dealing with exceptions
-            var tcs = new TaskCompletionSource<bool>();
-            using (new Timer(s => ((TaskCompletionSource<bool>)s!).SetResult(true), tcs, _waitTimeSpan, Timeout.InfiniteTimeSpan))
-            {
-                await Task.WhenAny(_processExit.Task, tcs.Task).ConfigureAwait(false);
-            }
+            await Task.Delay(25).ConfigureAwait(false);
         }
     }