WhenAny

51 references to WhenAny

ClientSample (1)

Tcp\TcpConnection.cs (1)

85if (await Task.WhenAny(receiveTask, sendTask) == sendTask)

HelixTestRunner (2)

ProcessUtil.cs (2)

175var result = await Task.WhenAny(processLifetimeTask.Task, canceledTcs.Task); 192await Task.WhenAny(processLifetimeTask.Task, Task.Delay(TimeSpan.FromSeconds(5), cancel.Token));

InMemory.FunctionalTests (6)

Http2\Http2StreamTests.cs (2)

1602var res = await Task.WhenAny(tcs.Task, Task.Delay(1000)) == tcs.Task; 4914await Task.WhenAny(WaitForStreamErrorAsync(1, Http2ErrorCode.INTERNAL_ERROR, expectedErrorMessage: null), appTcs.Task).Unwrap();

ResponseTests.cs (3)

158var completedTask = await Task.WhenAny(writeTask, timerTask); 165completedTask = await Task.WhenAny(writeTask, timerTask); 3106var res = await Task.WhenAny(tcs.Task, Task.Delay(1000)) == tcs.Task;

src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)

155var task = await Task.WhenAny(_allBlocksReturned.Task, Task.Delay(timeout));

Interop.FunctionalTests (2)

H2SpecCommands.cs (1)

254if (await Task.WhenAny(exitedTcs.Task, Task.Delay(TimeSpan.FromSeconds(TimeoutSeconds * 2))) != exitedTcs.Task)

Http3\Http3RequestTests.cs (1)

49await Task.WhenAny(_completeTcs.Task, cancellationTcs.Task);

Microsoft.AspNetCore.Components (1)

Routing\Router.cs (1)

303var task = await Task.WhenAny(OnNavigateAsync.InvokeAsync(navigateContext), cancellationTcs.Task);

Microsoft.AspNetCore.ConcurrencyLimiter.Tests (1)

TaskExtensions.cs (1)

14var completed = await Task.WhenAny(task, otherTask);

Microsoft.AspNetCore.Hosting.Tests (3)

WebHostTests.cs (3)

228Assert.Equal(task, await Task.WhenAny(task, Task.Delay(TimeSpan.FromSeconds(10)))); 264Assert.Equal(task, await Task.WhenAny(task, Task.Delay(TimeSpan.FromSeconds(10)))); 303Assert.Equal(task, await Task.WhenAny(task, Task.Delay(TimeSpan.FromSeconds(8))));

Microsoft.AspNetCore.Http.Connections (6)

Internal\HttpConnectionContext.cs (1)

336var result = await Task.WhenAny(applicationTask, transportTask);

Internal\HttpConnectionDispatcher.cs (2)

256var resultTask = await Task.WhenAny(connection.ApplicationTask!, connection.TransportTask!); 331await Task.WhenAny(connection.ApplicationTask!, connection.TransportTask!);

Internal\Transports\WebSocketsServerTransport.cs (3)

68var trigger = await Task.WhenAny(receiving, sending); 83var resultTask = await Task.WhenAny(sending, Task.Delay(_options.CloseTimeout, delayCts.Token)); 111var resultTask = await Task.WhenAny(receiving, Task.Delay(_options.CloseTimeout, delayCts.Token));

Microsoft.AspNetCore.Http.Connections.Client (4)

Internal\LongPollingTransport.cs (1)

80var trigger = await Task.WhenAny(receiving, sending).ConfigureAwait(false);

Internal\ServerSentEventsTransport.cs (1)

98var trigger = await Task.WhenAny(receiving, sending).ConfigureAwait(false);

Internal\WebSocketsTransport.cs (2)

354var trigger = await Task.WhenAny(receiving, sending).ConfigureAwait(false); 367var resultTask = await Task.WhenAny(sending, Task.Delay(_closeTimeout, _stopCts.Token)).ConfigureAwait(false);

Microsoft.AspNetCore.Http.Connections.Tests (1)

HttpConnectionDispatcherTests.cs (1)

1577var completedTask = await Task.WhenAny(request1, request2).DefaultTimeout();

Microsoft.AspNetCore.Server.HttpSys (1)

src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)

155var task = await Task.WhenAny(_allBlocksReturned.Task, Task.Delay(timeout));

Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (2)

Listener\Utilities.cs (2)

130var completedTask = await Task.WhenAny(acceptTask, Task.Delay(timeout)); 146var completedTask = await Task.WhenAny(acceptTask, responseTask);

Microsoft.AspNetCore.Server.IIS (1)

src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)

155var task = await Task.WhenAny(_allBlocksReturned.Task, Task.Delay(timeout));

Microsoft.AspNetCore.Server.Kestrel.Core (2)

Internal\Infrastructure\TransportConnectionManager.cs (2)

69return await Task.WhenAny(allClosedTask, CancellationTokenAsTask(token)).ConfigureAwait(false) == allClosedTask; 86return await Task.WhenAny(allAbortedTask, Task.Delay(1000)).ConfigureAwait(false) == allAbortedTask;

Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)

src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)

155var task = await Task.WhenAny(_allBlocksReturned.Task, Task.Delay(timeout));

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)

src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)

155var task = await Task.WhenAny(_allBlocksReturned.Task, Task.Delay(timeout));

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)

src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)

155var task = await Task.WhenAny(_allBlocksReturned.Task, Task.Delay(timeout));

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)

src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)

155var task = await Task.WhenAny(_allBlocksReturned.Task, Task.Delay(timeout));

Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)

src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)

155var task = await Task.WhenAny(_allBlocksReturned.Task, Task.Delay(timeout));

Microsoft.AspNetCore.SignalR.Client.Tests (1)

LongPollingTransportTests.cs (1)

670var completedTask = await Task.WhenAny(completionTcs.Task, longPollingTransport.Running).DefaultTimeout();

Microsoft.AspNetCore.SignalR.Specification.Tests (3)

Internal\TaskExtensions.cs (2)

25if (task == await Task.WhenAny(task, Task.Delay(timeout, cts.Token))) 49if (task == await Task.WhenAny(task, Task.Delay(timeout, cts.Token)))

src\SignalR\common\testassets\Tests.Utils\TaskExtensions.cs (1)

14var completed = await Task.WhenAny(task, otherTask);

Microsoft.AspNetCore.SignalR.Tests (1)

HubConnectionHandlerTests.ClientResult.cs (1)

301var task = await Task.WhenAny(tcsService.EndMethod.Task, client.ReadAsync()).DefaultTimeout();

Microsoft.AspNetCore.SignalR.Tests.Utils (1)

TaskExtensions.cs (1)

14var completed = await Task.WhenAny(task, otherTask);

Microsoft.AspNetCore.SpaServices.Extensions (2)

Util\TaskTimeoutExtensions.cs (2)

10if (task == await Task.WhenAny(task, Task.Delay(timeoutDelay))) 22if (task == await Task.WhenAny(task, Task.Delay(timeoutDelay)))

Microsoft.Extensions.Caching.Hybrid (1)

Internal\DefaultHybridCache.StampedeStateT.cs (1)

266var first = await System.Threading.Tasks.Task.WhenAny(stampede.Task, cancelStub.Task).ConfigureAwait(false);

Sockets.BindTests (1)

src\Servers\Kestrel\shared\test\TransportTestHelpers\HostNameIsReachableAttribute.cs (1)

41if (await Task.WhenAny(ConnectToHost(_hostname, 80), timeoutTask) == timeoutTask)

Sockets.FunctionalTests (1)

src\Servers\Kestrel\shared\test\TransportTestHelpers\HostNameIsReachableAttribute.cs (1)

41if (await Task.WhenAny(ConnectToHost(_hostname, 80), timeoutTask) == timeoutTask)

System.Net.Http (2)

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)

2026await Task.WhenAny(requestBodyTask, responseHeadersTask).ConfigureAwait(false) == requestBodyTask ||

System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)

181await Task.WhenAny(sendRequestTask, readResponseTask).ConfigureAwait(false) == sendRequestTask ||