fix(AsyncQueue): use TrySetResult to avoid throwing in case of error

Author: luca-schlecker

src/AsyncQueue.cs

@@ -50,7 +50,7 @@ public void Enqueue(T item)
         WaitWhileLimitReached(cts.Token);
         semaphore.Wait();
         if (waiters.TryDequeue(out var tcs))
-            tcs.SetResult(item);
+            tcs.TrySetResult(item);
         else
             queue.Enqueue(item);
         semaphore.Release();
@@ -67,7 +67,7 @@ public async Task EnqueueAsync(T item)
         await WaitWhileLimitReachedAsync(cts.Token);
         await semaphore.WaitAsync();
         if (waiters.TryDequeue(out var tcs))
-            tcs.SetResult(item);
+            tcs.TrySetResult(item);
         else
             queue.Enqueue(item);
         semaphore.Release();
@@ -86,7 +86,7 @@ public void EnqueueRange(IEnumerable<T> items)
         foreach (var item in items)
         {
             if (waiters.TryDequeue(out var tcs))
-                tcs.SetResult(item);
+                tcs.TrySetResult(item);
             else
                 queue.Enqueue(item);
         }
@@ -106,7 +106,7 @@ public async Task EnqueueRangeAsync(IEnumerable<T> items)
         foreach (var item in items)
         {
             if (waiters.TryDequeue(out var tcs))
-                tcs.SetResult(item);
+                tcs.TrySetResult(item);
             else
                 queue.Enqueue(item);
         }