WhenAny

69 references to WhenAny

Aspire.Dashboard.Components.Tests (1)

Layout\MainLayoutTests.cs (1)

120var completedTask = await Task.WhenAny(messageShownTcs.Task, timeoutTask).WaitAsync(TimeSpan.FromSeconds(5));

Aspire.EndToEnd.Tests (2)

tests\Shared\TemplatesTesting\AspireProject.cs (1)

291var completedTask = await Task.WhenAny(allOutputCompleteTask, allOutputCompleteTimeoutTask).ConfigureAwait(false);

tests\Shared\TemplatesTesting\ToolCommand.cs (1)

164var completedTask = await Task.WhenAny(waitForExitTask, Task.Delay(TimeSpan.FromSeconds(5), token)).ConfigureAwait(false);

Aspire.Templates.Tests (2)

tests\Shared\TemplatesTesting\AspireProject.cs (1)

291var completedTask = await Task.WhenAny(allOutputCompleteTask, allOutputCompleteTimeoutTask).ConfigureAwait(false);

tests\Shared\TemplatesTesting\ToolCommand.cs (1)

164var completedTask = await Task.WhenAny(waitForExitTask, Task.Delay(TimeSpan.FromSeconds(5), token)).ConfigureAwait(false);

ClientSample (1)

Tcp\TcpConnection.cs (1)

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

csc (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

302await Task.WhenAny(responseTask, monitorTask).ConfigureAwait(false);

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)

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

ResponseTests.cs (3)

162var completedTask = await Task.WhenAny(writeTask, timerTask); 169completedTask = await Task.WhenAny(writeTask, timerTask); 3334var 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)

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

Microsoft.AspNetCore.Components (1)

Routing\Router.cs (1)

330var 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)

97var 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; 91return 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.Build.Tasks.CodeAnalysis (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

302await Task.WhenAny(responseTask, monitorTask).ConfigureAwait(false);

Microsoft.CodeAnalysis.Workspaces.UnitTests (4)

WorkspaceTests\AdhocWorkspaceTests.cs (4)

437await Task.WhenAny(tcs.Task, Task.Delay(1000)); 472await Task.WhenAny(tcs.Task, Task.Delay(1000)); 504await Task.WhenAny(tcs.Task, Task.Delay(1000)); 535await Task.WhenAny(tcs.Task, Task.Delay(1000));

Microsoft.Extensions.Caching.Hybrid (1)

Internal\DefaultHybridCache.StampedeStateT.cs (1)

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

Microsoft.Maui.Essentials (1)

Types\Shared\Utils.shared.cs (1)

36 var retTask = await Task.WhenAny(task, Task.Delay(timeSpan))

Replay (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

302await Task.WhenAny(responseTask, monitorTask).ConfigureAwait(false);

RunTests (1)

Program.cs (1)

105var finishedTask = await Task.WhenAny(timeoutTask, runTask);

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)

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

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

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

System.Net.Requests (1)

System\Net\HttpWebRequest.cs (1)

1105Task result = await Task.WhenAny(getStreamTask, _sendRequestTask).ConfigureAwait(false);

vbc (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

302await Task.WhenAny(responseTask, monitorTask).ConfigureAwait(false);

VBCSCompiler (2)

src\Compilers\Server\VBCSCompiler\ClientConnectionHandler.cs (1)

118await Task.WhenAny(compilationTask, clientConnection.DisconnectTask).ConfigureAwait(false);

src\Compilers\Shared\BuildServerConnection.cs (1)

302await Task.WhenAny(responseTask, monitorTask).ConfigureAwait(false);