Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -126,9 +126,6 @@ internal async Task PingPong(QuicConnection client, QuicConnection server)

internal async Task RunClientServer(Func<QuicConnection, Task> clientFunction, Func<QuicConnection, Task> serverFunction, int iterations = 1, int millisecondsTimeout = 30_000, QuicListenerOptions listenerOptions = null)
{
const long ClientCloseErrorCode = 11111;
const long ServerCloseErrorCode = 22222;

using QuicListener listener = CreateQuicListener(listenerOptions ?? CreateQuicListenerOptions());

using var serverFinished = new SemaphoreSlim(0);
Expand All @@ -145,7 +142,6 @@ await new[]

serverFinished.Release();
await clientFinished.WaitAsync();
await serverConnection.CloseAsync(ServerCloseErrorCode);
}),
Task.Run(async () =>
{
Expand All @@ -155,7 +151,6 @@ await new[]

clientFinished.Release();
await serverFinished.WaitAsync();
await clientConnection.CloseAsync(ClientCloseErrorCode);
})
}.WhenAllOrAnyFailed(millisecondsTimeout);
}
Expand Down