WaitAsync

79 references to WaitAsync

Aspire.Dashboard (4)

Components\Interactions\InteractionsProvider.cs (4)

56await _semaphore.WaitAsync(_cts.Token).ConfigureAwait(false); 140await _semaphore.WaitAsync(_cts.Token).ConfigureAwait(false); 289await _semaphore.WaitAsync(_cts.Token).ConfigureAwait(false); 333await _semaphore.WaitAsync(_cts.Token).ConfigureAwait(false);

Aspire.Hosting (2)

Dcp\DcpDependencyCheck.cs (1)

33await _lock.WaitAsync(cancellationToken).ConfigureAwait(false);

Dcp\DcpExecutor.cs (1)

331await outputSemaphore.WaitAsync(pipelineCancellationToken).ConfigureAwait(false);

Aspire.Hosting.DevTunnels (1)

CoalescingAsyncOperation.cs (1)

32await _gate.WaitAsync(cancellationToken).ConfigureAwait(false);

GenerateDocumentationAndConfigFiles (1)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

Metrics (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Metrics.Legacy (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Microsoft.AspNetCore.Components.Server (2)

Circuits\HybridCacheCircuitPersistenceProvider.cs (2)

50await _lock.WaitAsync(cancellation); 69await _lock.WaitAsync(cancellation);

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

HttpConnection.cs (1)

218await _connectionLock.WaitAsync(cancellationToken).ConfigureAwait(false);

Microsoft.AspNetCore.OutputCaching.StackExchangeRedis (1)

RedisOutputCacheStore.cs (1)

326await _connectionLock.WaitAsync(token).ConfigureAwait(false);

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

Internal\KestrelServerImpl.cs (1)

292await _bindSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

Microsoft.AspNetCore.SignalR.Client.Core (3)

HubConnection.cs (1)

2494return _connectionLock.WaitAsync(token);

src\SignalR\common\Shared\MessageBuffer.cs (2)

159await _writeLock.WaitAsync(cancellationToken: default).ConfigureAwait(false); 190await _writeLock.WaitAsync(cancellationToken: default).ConfigureAwait(false);

Microsoft.AspNetCore.SignalR.Core (4)

HubConnectionContext.cs (2)

347await _writeLock.WaitAsync(cancellationToken); 373await _writeLock.WaitAsync(cancellationToken);

src\SignalR\common\Shared\MessageBuffer.cs (2)

159await _writeLock.WaitAsync(cancellationToken: default).ConfigureAwait(false); 190await _writeLock.WaitAsync(cancellationToken: default).ConfigureAwait(false);

Microsoft.AspNetCore.TestHost (1)

TestWebSocket.cs (1)

265await _sem.WaitAsync(cancellationToken);

Microsoft.AspNetCore.TestHost.Tests (1)

TestClientTests.cs (1)

1017await sem.WaitAsync(ctx.RequestAborted);

Microsoft.AspNetCore.WebSockets.Tests (1)

BufferStream.cs (1)

174await _readLock.WaitAsync(cancellationToken);

Microsoft.CodeAnalysis (1)

InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.Analyzers (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Microsoft.CodeAnalysis.AnalyzerUtilities (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Microsoft.CodeAnalysis.BannedApiAnalyzers (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Microsoft.CodeAnalysis.CodeStyle (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Microsoft.CodeAnalysis.Features (3)

ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingAsyncWorkItemQueue.cs (1)

66=> _semaphore.WaitAsync(cancellationToken);

ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingSemanticChangeProcessor.cs (2)

75=> _gate.WaitAsync(cancellationToken); 397=> _gate.WaitAsync(cancellationToken);

Microsoft.CodeAnalysis.InteractiveHost (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Microsoft.CodeAnalysis.PublicApiAnalyzers (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Microsoft.CodeAnalysis.ResxSourceGenerator (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

Microsoft.CodeAnalysis.Workspaces (1)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

Microsoft.Extensions.Caching.Hybrid.Tests (6)

StampedeTests.cs (6)

342await semaphore.WaitAsync(CancellationToken.None); 349await semaphore.WaitAsync(CancellationToken.None); 382await semaphore.WaitAsync(CancellationToken.None); 389await semaphore.WaitAsync(CancellationToken.None); 426await semaphore.WaitAsync(CancellationToken.None); 433await semaphore.WaitAsync(CancellationToken.None);

Microsoft.Extensions.Caching.StackExchangeRedis (1)

RedisCache.cs (1)

329await _connectionLock.WaitAsync(token).ConfigureAwait(false);

Microsoft.Extensions.ServiceDiscovery.Tests (1)

ServiceEndpointResolverTests.cs (1)

219await sem.WaitAsync(ct).ConfigureAwait(false);

Microsoft.Maui.Essentials (1)

TextToSpeech\TextToSpeech.shared.cs (1)

178 await semaphore.WaitAsync(cancelToken);

Roslyn.Diagnostics.Analyzers (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);

System.Private.CoreLib (11)

src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (5)

317await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false); 589Task semaphoreLockTask = sem.WaitAsync(cancellationToken); 640Task semaphoreLockTask = sem.WaitAsync(cancellationToken); 1017Task semaphoreLockTask = sem.WaitAsync(cancellationToken); 1289await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false);

src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (6)

311Task semaphoreLockTask = semaphore.WaitAsync(cancellationToken); 355await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false); 611Task semaphoreLockTask = semaphore.WaitAsync(cancellationToken); 662await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false); 797await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false); 845await EnsureAsyncActiveSemaphoreInitialized().WaitAsync(cancellationToken).ConfigureAwait(false);

System.Security.Cryptography (2)

System\Security\Cryptography\CryptoStream.cs (2)

240await AsyncActiveSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false); 479await AsyncActiveSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

System.ServiceModel.Primitives (2)

System\ServiceModel\Channels\BufferedReadStream.cs (1)

322Task semaphoreLockTask = _sem.WaitAsync(cancellationToken);

System\ServiceModel\Channels\BufferedWriteStream.cs (1)

423Task semaphoreLockTask = _sem.WaitAsync(cancellationToken);

System.Threading.Tasks.Parallel (1)

System\Threading\Tasks\Parallel.ForEachAsync.cs (1)

602return _lock.WaitAsync(CancellationToken.None);

Test.Utilities (1)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

Text.Analyzers (2)

src\Compilers\Core\Portable\InternalUtilities\SemaphoreSlimExtensions.cs (1)

23await semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);

src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (1)

489return _lock.WaitAsync(CancellationToken.None);