Skip to content

Commit de4dc6d

Browse files
committed
Remove completed commands
1 parent 2a55160 commit de4dc6d

File tree

1 file changed

+3
-0
lines changed
  • dotnet/src/webdriver/BiDi/Communication

1 file changed

+3
-0
lines changed

dotnet/src/webdriver/BiDi/Communication/Broker.cs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,8 @@ private async Task ReceiveMessagesAsync(CancellationToken cancellationToken)
140140
var messageSuccess = JsonSerializer.Deserialize(ref utfJsonReader, successCommand.Item1.ResultType, _jsonSerializerContext);
141141

142142
successCommand.Item2.SetResult(messageSuccess);
143+
144+
_pendingCommands.TryRemove(successId, out _);
143145
break;
144146

145147
case "event":
@@ -166,6 +168,7 @@ private async Task ReceiveMessagesAsync(CancellationToken cancellationToken)
166168
var messageError = JsonSerializer.Deserialize(ref utfJsonReader, _jsonSerializerContext.MessageError);
167169
var errorCommand = _pendingCommands[messageError.Id];
168170
errorCommand.Item2.SetException(new BiDiException($"{messageError.Error}: {messageError.Message}"));
171+
_pendingCommands.TryRemove(messageError.Id, out _);
169172
break;
170173
}
171174
}

0 commit comments

Comments
 (0)