Skip to content

Commit 3a5d190

Browse files
authored
Remove handlers when used. (#8)
1 parent 7804745 commit 3a5d190

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

RabbitExpress/QueueClient.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ private async Task Consumer_Received(object sender, BasicDeliverEventArgs @event
129129
await Task.Yield();
130130

131131
// Handle pending RPC Requests
132-
if (@event.BasicProperties.CorrelationId != null && _pending.TryGetValue(@event.BasicProperties.CorrelationId, out Func<byte[], WorkerResult> handler))
132+
if (@event.BasicProperties.CorrelationId != null && _pending.TryRemove(@event.BasicProperties.CorrelationId, out Func<byte[], WorkerResult> handler))
133133
{
134134
HandleMessage(handler, @event);
135135
return;

0 commit comments

Comments
 (0)