Skip to content

Commit 35adce2

Browse files
committed
[dotnet] [bidi] Use sync version of writing to memory stream while receiving messages
1 parent 727fae0 commit 35adce2

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

dotnet/src/webdriver/BiDi/Communication/Transport/WebSocketTransport.cs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public async Task<byte[]> ReceiveAsync(CancellationToken cancellationToken)
5252
{
5353
result = await _webSocket.ReceiveAsync(_receiveBuffer, cancellationToken).ConfigureAwait(false);
5454

55-
await _sharedMemoryStream.WriteAsync(_receiveBuffer.Array!, _receiveBuffer.Offset, result.Count, cancellationToken).ConfigureAwait(false);
55+
_sharedMemoryStream.Write(_receiveBuffer.Array!, _receiveBuffer.Offset, result.Count);
5656
}
5757
while (!result.EndOfMessage);
5858

@@ -68,12 +68,10 @@ public async Task<byte[]> ReceiveAsync(CancellationToken cancellationToken)
6868

6969
public async Task SendAsync(byte[] data, CancellationToken cancellationToken)
7070
{
71-
var semaphoreTask = _socketSendSemaphoreSlim.WaitAsync(cancellationToken);
71+
await _socketSendSemaphoreSlim.WaitAsync(cancellationToken).ConfigureAwait(false);
7272

7373
try
7474
{
75-
await semaphoreTask.ConfigureAwait(false);
76-
7775
if (_logger.IsEnabled(LogEventLevel.Trace))
7876
{
7977
_logger.Trace($"BiDi SND --> {Encoding.UTF8.GetString(data)}");

0 commit comments

Comments
 (0)