File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed
projects/client/RabbitMQ.Client/src/util Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change 46
46
namespace RabbitMQ . Util
47
47
{
48
48
/// <summary>
49
- /// A concurrent queue where Dequeue waits for something to be inserted if the queue is empty and Enqueue signals
50
- /// that something has been added. Similar in function to a BlockingCollection but with async/await
51
- /// support.
49
+ /// A concurrent queue where Dequeue waits for something to be added if the queue is empty and Enqueue signals
50
+ /// that something has been added. Similar in function to a BlockingCollection but with async/await
51
+ /// support.
52
52
/// </summary>
53
- /// <typeparam name="T"></typeparam>
53
+ /// <typeparam name="T">
54
+ /// Queue element type
55
+ /// </typeparam>
54
56
internal class AsyncConcurrentQueue < T >
55
57
{
56
58
private readonly ConcurrentQueue < T > _internalQueue = new ConcurrentQueue < T > ( ) ;
@@ -67,7 +69,7 @@ public async Task<T> DequeueAsync(CancellationToken token = default)
67
69
68
70
if ( ! _internalQueue . TryDequeue ( out var command ) )
69
71
{
70
- throw new InvalidOperationException ( "Internal queue empty despite signaled enqueue. " ) ;
72
+ throw new InvalidOperationException ( "Internal queue is empty despite receiving an enqueueing signal " ) ;
71
73
}
72
74
73
75
return command ;
You can’t perform that action at this time.
0 commit comments