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

luca-schlecker · May 20, 2024 · 43a9e07 · 43a9e07
1 parent 2ce90ef
commit 43a9e07
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/AsyncQueue.cs b/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);
         }