Skip to content

Commit

Permalink
Loop style.
Browse files Browse the repository at this point in the history
  • Loading branch information
danielcweber committed Mar 14, 2024
1 parent ad68be4 commit e9f10e9
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions src/Providers.Core/Extensions/ClientWebSocketExtensions.cs
Original file line number Diff line number Diff line change
Expand Up @@ -13,23 +13,23 @@ public static async Task<MemoryOwner<byte>> ReceiveAsync(this ClientWebSocket cl

try
{
while (true)
ValueWebSocketReceiveResult result;

do
{
ct.ThrowIfCancellationRequested();

if (read == bytes.Memory.Length)
bytes = bytes.Double();

var result = await client.ReceiveAsync(bytes.Memory[read..], ct);
result = await client.ReceiveAsync(bytes.Memory[read..], ct);

if (result.MessageType == WebSocketMessageType.Close)
throw new ObjectDisposedException(client.GetType().Name);

Check warning on line 28 in src/Providers.Core/Extensions/ClientWebSocketExtensions.cs

View check run for this annotation

Codecov / codecov/patch

src/Providers.Core/Extensions/ClientWebSocketExtensions.cs#L28

Added line #L28 was not covered by tests

read += result.Count;

if (result.EndOfMessage)
break;
}
while (!result.EndOfMessage);

return bytes[..read];
}
Expand Down

0 comments on commit e9f10e9

Please sign in to comment.