240CancellationToken.None,

94}, CancellationToken.None); 396_ = Task.Run(async () => await DisconnectAsync(connection).ConfigureAwait(false), CancellationToken.None);

855await ConnectAsync(CancellationToken.None); 866CancellationToken.None);

73=> GetTrustLevel(certificate, CancellationToken.None);

497var childExitTask = childProcess.WaitForExitAsync(CancellationToken.None); 653CancellationToken.None); 860CancellationToken.None,

212CancellationToken.None).ConfigureAwait(false);

171if (await Task.WhenAny(layoutTask, Task.Delay(s_bundleStatusDelay, CancellationToken.None)).ConfigureAwait(false) == layoutTask)

38CancellationToken.None);

357await backchannel.RequestStopAsync(CancellationToken.None).ConfigureAwait(false);

215}, CancellationToken.None);

277await CancelAppHostRunAsync(runCts, runTask, cleanupTimeout, CancellationToken.None).ConfigureAwait(false); 757await detachedAppHostRun.WaitAsync(s_detachedAppHostTeardownTimeout, _timeProvider, CancellationToken.None).ConfigureAwait(false); 871CancellationToken.None, 912var resolution = await ResolveAppHostExitCodeAsync(pendingRun, CancellationToken.None).ConfigureAwait(false);

126CancellationToken.None,

61await process.WaitForExitAsync(CancellationToken.None);

222await DrainOutputAsync(process, CancellationToken.None).ConfigureAwait(false); 270return ShutdownLadderAsync(process, signaler: null, gracefulToken: CancellationToken.None); 542await DrainOutputAsync(process, CancellationToken.None).ConfigureAwait(false);

69PumpTask = Task.Run(ProcessExtensionTaskChannelAsync, CancellationToken.None);

94if (!await execution.StartAsync(CancellationToken.None).ConfigureAwait(false))

50var stderrTask = dcpProcess.StandardError.ReadToEndAsync(CancellationToken.None); 51var stdoutLineTask = dcpProcess.StandardOutput.ReadLineAsync(CancellationToken.None).AsTask(); 60await dcpProcess.WaitForExitAsync(CancellationToken.None).ConfigureAwait(false); 85await dcpProcess.WaitForExitAsync(CancellationToken.None).ConfigureAwait(false); 119await dcpProcess.WaitForExitAsync(CancellationToken.None).ConfigureAwait(false); 141CancellationToken.None,

263_dashboardExitTask = dashboardProcess.WaitForExitAsync(CancellationToken.None);

79var result = await FetchAppHostInfoCoreAsync(projectFile, CancellationToken.None).ConfigureAwait(false);

497!string.Equals(AppHostServerClosureManifest.ComputeFileHash(copiedPath, CancellationToken.None), entry.FileContentHash, StringComparison.Ordinal))

450CancellationToken.None,

714await execution.StartAsync(CancellationToken.None).ConfigureAwait(false);

591CancellationToken.None,

1445await execution.StartAsync(CancellationToken.None).ConfigureAwait(false);

219await File.WriteAllBytesAsync(manifest.File.FullName, originalFiles[manifest.File.FullName], CancellationToken.None);

66services.GetRequiredService<CliExecutionContext>(), UploaderName, CancellationToken.None).ConfigureAwait(false); 83await using var process = await IsolatedProcess.StartAsync(startInfo, CancellationToken.None).ConfigureAwait(false);

392var cancellationToken = timeoutSource?.Token ?? CancellationToken.None;

416}, CancellationToken.None);

280var timeout = Task.Delay(TimeSpan.FromSeconds(2), CancellationToken.None); 549await connection.RequestPrimaryAsync(availW, availH, CancellationToken.None).ConfigureAwait(false); 590await connection.RequestPrimaryAsync(width, height, CancellationToken.None).ConfigureAwait(false);

64var checkTask = Task.Run(() => check.CheckAsync(checkTimeoutCts.Token), CancellationToken.None); 69CancellationToken.None,

248CancellationToken.None,

23await applicator.ApplyAsync(CancellationToken.None).DefaultTimeout();

22var applicators = await detector.DetectAsync(context, CancellationToken.None).DefaultTimeout(); 39var applicators = await detector.DetectAsync(context, CancellationToken.None).DefaultTimeout(); 63var applicators = await detector.DetectAsync(context, CancellationToken.None).DefaultTimeout(); 92var applicators = await detector.DetectAsync(context, CancellationToken.None).DefaultTimeout(); 111var applicators = await detector.DetectAsync(context, CancellationToken.None).DefaultTimeout();

44var files = await bundle.GetSkillFilesAsync(AspireSkillDefinition, CancellationToken.None); 72var files = await bundle.GetSkillFilesAsync(AspireSkillDefinition, CancellationToken.None); 622CancellationToken.None)); 666var files = await bundle.GetSkillFilesAsync(AspireifySkillDefinition, CancellationToken.None); 826CancellationToken.None,

51var result = await installer.InstallAsync(CancellationToken.None); 119var installTask = installer.InstallAsync(CancellationToken.None); 173var result = await installer.InstallAsync(CancellationToken.None); 226var result = await installer.InstallAsync(CancellationToken.None); 236var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 282var firstResult = await installer.InstallAsync(CancellationToken.None); 290var secondResult = await secondInstaller.InstallAsync(CancellationToken.None); 339var result = await installer.InstallAsync(CancellationToken.None); 357var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 385var oldResult = await oldInstaller.InstallAsync(CancellationToken.None); 399var result = await installer.InstallAsync(CancellationToken.None); 415CancellationToken.None)); 427var restoredResult = await restoredInstaller.InstallAsync(CancellationToken.None); 455var result = await installer.InstallAsync(CancellationToken.None); 497var result = await installer.InstallAsync(CancellationToken.None); 503var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 532var result = await installer.InstallAsync(CancellationToken.None); 574var result = await installer.InstallAsync(CancellationToken.None); 621var result = await installer.InstallAsync(CancellationToken.None); 668var result = await installer.InstallAsync(CancellationToken.None); 729var installTask = installer.InstallAsync(CancellationToken.None); 790var result = await installer.InstallAsync(CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(10)); 800var cleanupResult = await installer.InstallAsync(CancellationToken.None); 850var result = await installer.InstallAsync(CancellationToken.None); 878var result = await installer.InstallAsync(CancellationToken.None); 967var result = await installer.InstallAsync(CancellationToken.None); 1016firstInstallTask = firstInstaller.InstallAsync(CancellationToken.None); 1030var secondResult = await secondInstaller.InstallAsync(CancellationToken.None); 1064var result = await installer.InstallAsync(CancellationToken.None); 1086var result = await installer.InstallAsync(CancellationToken.None); 1113var result = await installer.InstallAsync(CancellationToken.None); 1141var result = await installer.InstallAsync(CancellationToken.None); 1199var result = await installer.InstallAsync(CancellationToken.None); 1205var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 1248var result = await installer.InstallAsync(CancellationToken.None); 1254var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 1302var result = await installer.InstallAsync(CancellationToken.None); 1309var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 1364var result = await installer.InstallAsync(CancellationToken.None); 1371var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 1403var result = await installer.InstallAsync(CancellationToken.None); 1416var migrationFiles = await result.Bundle.GetSkillFilesAsync(migrationSkill, CancellationToken.None); 1454var bundle = await provider.CreateBundleAsync(bundleDirectory, CancellationToken.None); 1488var bundle = await provider.CreateBundleAsync(stageDirectory, CancellationToken.None); 1521CancellationToken.None)); 1551CancellationToken.None)); 1624var result = await installer.InstallAsync(CancellationToken.None); 1689var result = await installer.InstallAsync(CancellationToken.None); 1696var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 1744var result = await installer.InstallAsync(CancellationToken.None); 1751var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 1803var result = await installer.InstallAsync(CancellationToken.None); 1813var skillFile = Assert.Single(await result.Bundle.GetSkillFilesAsync(skill, CancellationToken.None)); 1842var result = await installer.InstallAsync(CancellationToken.None); 1874var result = await installer.InstallAsync(CancellationToken.None); 1909var result = await installer.InstallAsync(CancellationToken.None); 1945var result = await installer.InstallAsync(CancellationToken.None); 1998var result = await installer.InstallAsync(CancellationToken.None);

33await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 41() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout(); 61await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 67() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout(); 87await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 93() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout();

30await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 51await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 57await aspireApplicator.ApplyAsync(CancellationToken.None).DefaultTimeout(); 107await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 108await context.Applicators.First(applicator => applicator.Description.Contains("Aspire MCP")).ApplyAsync(CancellationToken.None).DefaultTimeout(); 139await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 140await context.Applicators[0].ApplyAsync(CancellationToken.None).DefaultTimeout(); 179await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 196await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 212await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 226await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 242await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 281await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 289() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout(); 309await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 315() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout(); 333await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 336() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout(); 361await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 367() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout();

18_ = await runner.GetVersionAsync(CancellationToken.None);

30await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 38() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout(); 56await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 62() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout(); 80await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 86() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout();

39var (status, message) = await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 72var (status, _) = await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 108await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 142var (status, _) = await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 173var (status, message) = await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 215var (status, _) = await installer.InstallAsync(repoRoot, s_emptySkillDirs, CancellationToken.None); 260var (status, _) = await installer.InstallAsync(repoRoot, s_emptySkillDirs, CancellationToken.None); 303var (status, message) = await installer.InstallAsync(repoRoot, s_emptySkillDirs, CancellationToken.None); 351var (status, _) = await installer.InstallAsync(repoRoot, s_emptySkillDirs, CancellationToken.None); 409await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 447var (status, message) = await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 493var (status, _) = await installer.InstallAsync(repoRoot, s_emptySkillDirs, CancellationToken.None); 536await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 574var (status, message) = await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 606await installer.InstallAsync(tempDir, s_emptySkillDirs, CancellationToken.None); 658await installer.InstallAsync(tempDir, selectedDirs, CancellationToken.None); 752await installer.InstallAsync(tempDir, selectedDirs, CancellationToken.None); 803await installer.InstallAsync(tempDir, selectedDirs, CancellationToken.None); 852await installer.InstallAsync(tempDir, selectedDirs, CancellationToken.None);

1223CancellationToken.None);

22var result = await configurator.ConfigureAsync([AgentClientKind.CopilotCli], CancellationToken.None).DefaultTimeout(); 53CancellationToken.None).DefaultTimeout(); 71await configurator.ConfigureAsync([AgentClientKind.CopilotCli], CancellationToken.None).DefaultTimeout(); 84var result = await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None).DefaultTimeout(); 110await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None).DefaultTimeout(); 111await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None).DefaultTimeout(); 146await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None).DefaultTimeout(); 166await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None); 167await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None); 188var result = await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None).DefaultTimeout(); 230await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None); 231await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None); 253var result = await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None).DefaultTimeout(); 273var result = await configurator.ConfigureAsync([AgentClientKind.ClaudeCode], CancellationToken.None).DefaultTimeout(); 288CancellationToken.None).DefaultTimeout();

24var scripts = await installer.EnsureInstalledAsync(CancellationToken.None).DefaultTimeout(); 42var bundle = await bundleProvider.CreateBundleAsync(bundleDirectory, CancellationToken.None).DefaultTimeout(); 45var scripts = await CreateInstaller(workspace, home).EnsureInstalledAsync(CancellationToken.None).DefaultTimeout(); 88var scripts = await installer.EnsureInstalledAsync(CancellationToken.None).DefaultTimeout(); 106var first = await installer.EnsureInstalledAsync(CancellationToken.None).DefaultTimeout(); 109var second = await installer.EnsureInstalledAsync(CancellationToken.None).DefaultTimeout(); 128var scripts = await installer.EnsureInstalledAsync(CancellationToken.None).DefaultTimeout(); 147var scripts = await installer.EnsureInstalledAsync(CancellationToken.None).DefaultTimeout();

560return await installer.EnsureInstalledAsync(CancellationToken.None);

29await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 47await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 65await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 79await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 97await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 116await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 123await aspireApplicator.ApplyAsync(CancellationToken.None).DefaultTimeout(); 140await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 141await context.Applicators[0].ApplyAsync(CancellationToken.None).DefaultTimeout(); 196await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 197await context.Applicators[0].ApplyAsync(CancellationToken.None).DefaultTimeout(); 237await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 243await aspireApplicator.ApplyAsync(CancellationToken.None).DefaultTimeout(); 268await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 289await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 297() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout(); 317await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 323() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout(); 343await scanner.ScanAsync(context, CancellationToken.None).DefaultTimeout(); 349() => aspireApplicator.ApplyAsync(CancellationToken.None)).DefaultTimeout();

152return await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(new TestAppHostSocket("socket.hash1"), isInScope: true, NullLogger.Instance, new ProfilingTelemetry(new ConfigurationBuilder().Build()), clientSocket, timeout, CancellationToken.None).DefaultTimeout(); 155return await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(new TestAppHostSocket("socket.hash1"), isInScope: true, NullLogger.Instance, new ProfilingTelemetry(new ConfigurationBuilder().Build()), clientSocket, CancellationToken.None).DefaultTimeout();

38() => backchannel.UploadFileAsync(tempFile, "large.bin", 1, "File", CancellationToken.None));

38await Assert.ThrowsAsync<ArgumentException>(() => backchannel.ConnectAsync(CancellationToken.None)).DefaultTimeout(); 39await Assert.ThrowsAsync<ArgumentException>(() => backchannel.ConnectAsync(CancellationToken.None)).DefaultTimeout(); 59var firstConnectTask = backchannel.ConnectAsync(CancellationToken.None); 63.Select(_ => backchannel.ConnectAsync(CancellationToken.None)) 74var retryException = await Assert.ThrowsAsync<InvalidOperationException>(() => backchannel.ConnectAsync(CancellationToken.None)).DefaultTimeout(); 97var firstConnectTask = backchannel.ConnectAsync(CancellationToken.None); 101.Select(_ => backchannel.ConnectAsync(CancellationToken.None)) 112var retryException = await Assert.ThrowsAsync<ExtensionIncompatibleException>(() => backchannel.ConnectAsync(CancellationToken.None)).DefaultTimeout(); 149.Select(_ => backchannel.ConnectAsync(CancellationToken.None))

211var collected = await collector.CollectAsync(CancellationToken.None); 240var collected = await collector.CollectAsync(CancellationToken.None); 266var collected = await collector.CollectAsync(CancellationToken.None); 298var collected = await collector.CollectAsync(CancellationToken.None); 322var collected = await collector.CollectAsync(CancellationToken.None); 345var collected = await collector.CollectAsync(CancellationToken.None); 363await Assert.ThrowsAsync<OperationCanceledException>(() => collector.CollectAsync(CancellationToken.None));

614await BundleService.ExtractPayloadAsync(stream, dest, new TestEnvironment(), CancellationToken.None);

69var miss = await cache.TryGetAsync(projectFile, CancellationToken.None).DefaultTimeout(); 72await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 76var hit = await cache.TryGetAsync(freshProject, CancellationToken.None).DefaultTimeout(); 95await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry() with { RunCommand = null }, CancellationToken.None).DefaultTimeout(); 97var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 113CancellationToken.None).DefaultTimeout(); 148await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 156var hit = await cache.TryGetAsync(freshProject, CancellationToken.None).DefaultTimeout(); 167await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 174var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 185await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 191var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 207await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 208var hit = await cache.TryGetAsync(projectFile, CancellationToken.None).DefaultTimeout(); 226await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 227var hit = await cache.TryGetAsync(projectFile, CancellationToken.None).DefaultTimeout(); 246return cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), entry, CancellationToken.None); 252var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 270await cache.SetAsync(new FileInfo(projectFile.FullName), expectedKey, SampleEntry(), CancellationToken.None).DefaultTimeout(); 272var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 299await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry() with { IsAspireHost = false }, CancellationToken.None).DefaultTimeout(); 300Assert.NotNull(await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout()); 311var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 331await cache.SetAsync(new FileInfo(projectFile.FullName), cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 332var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 368await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry() with { IsAspireHost = false }, CancellationToken.None).DefaultTimeout(); 369Assert.NotNull(await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout()); 380var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 402await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry() with { IsAspireHost = false }, CancellationToken.None).DefaultTimeout(); 403Assert.NotNull(await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout()); 414Assert.Null(await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout()); 431await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 433Assert.Null(await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout()); 459await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 460var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 488await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry() with { IsAspireHost = false }, CancellationToken.None).DefaultTimeout(); 489Assert.NotNull(await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout()); 500var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 519await cache.SetAsync(new FileInfo(projectFile.FullName), cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 520var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 538await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 540Assert.Null(await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout()); 575await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 577var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 604await cache.SetAsync(projectFile, cache.GetCacheKey(projectFile), SampleEntry() with { IsAspireHost = false }, CancellationToken.None).DefaultTimeout(); 605Assert.NotNull(await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout()); 616var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 636await cache.SetAsync(new FileInfo(projectFile.FullName), cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 637var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout(); 660await cache.SetAsync(new FileInfo(projectFile.FullName), cache.GetCacheKey(projectFile), SampleEntry(), CancellationToken.None).DefaultTimeout(); 662var hit = await cache.TryGetAsync(new FileInfo(projectFile.FullName), CancellationToken.None).DefaultTimeout();

33var miss = await cache.GetAsync(key, CancellationToken.None).DefaultTimeout(); 36await cache.SetAsync(key, "RESULT-A", CancellationToken.None).DefaultTimeout(); 37var hit = await cache.GetAsync(key, CancellationToken.None).DefaultTimeout(); 53await cache.SetAsync(key, "RESULT-B", CancellationToken.None).DefaultTimeout(); 57var after = await cache.GetAsync(key, CancellationToken.None).DefaultTimeout(); 73await cache.SetAsync(key, "OLD", CancellationToken.None).DefaultTimeout(); 76await cache.SetAsync(key, "NEW", CancellationToken.None).DefaultTimeout(); 78var val = await cache.GetAsync(key, CancellationToken.None).DefaultTimeout(); 94await cache.SetAsync(key, "VALUE", CancellationToken.None).DefaultTimeout(); 95var before = await cache.GetAsync(key, CancellationToken.None).DefaultTimeout(); 97await cache.ClearAsync(CancellationToken.None).DefaultTimeout(); 98var after = await cache.GetAsync(key, CancellationToken.None).DefaultTimeout(); 113await cache.SetAsync(key, "VALUE-X", CancellationToken.None).DefaultTimeout(); 129var val = await cache.GetAsync(key, CancellationToken.None).DefaultTimeout();

2229await prompter.PromptForIntegrationAsync(packages, CancellationToken.None).DefaultTimeout(); 2278var result = await prompter.PromptForIntegrationVersionAsync(packages, configuredChannel: null, CancellationToken.None).DefaultTimeout(); 2330await prompter.PromptForIntegrationVersionAsync(packages, configuredChannel: null, CancellationToken.None).DefaultTimeout(); 2381var result = await prompter.PromptForIntegrationVersionAsync(packages, configuredChannel: "daily", CancellationToken.None).DefaultTimeout(); 2418var result = await prompter.PromptForIntegrationVersionAsync(packages, PackageChannelNames.Staging, CancellationToken.None).DefaultTimeout(); 2455var packages = (await stagingChannel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()) 2464var result = await prompter.PromptForIntegrationVersionAsync(packages, PackageChannelNames.Staging, CancellationToken.None).DefaultTimeout();

736CancellationToken.None).DefaultTimeout(); 769CancellationToken.None).DefaultTimeout(); 981CancellationToken.None);

576var result = await agentMcpCommand.ExecuteCommandAsync(parseResult, CancellationToken.None).DefaultTimeout();

76var ready = await AppHostLauncher.WaitForAppHostReadyAsync(connection, CancellationToken.None).DefaultTimeout(); 90var exception = await Assert.ThrowsAsync<IOException>(() => AppHostLauncher.WaitForAppHostReadyAsync(connection, CancellationToken.None)).DefaultTimeout(); 102CancellationToken.None).DefaultTimeout(); 117CancellationToken.None).DefaultTimeout(); 146CancellationToken.None); 194CancellationToken.None).DefaultTimeout(); 227CancellationToken.None).DefaultTimeout(); 256CancellationToken.None).DefaultTimeout(); 295CancellationToken.None).DefaultTimeout(TimeSpan.FromSeconds(60)); 322CancellationToken.None).DefaultTimeout(); 350CancellationToken.None).DefaultTimeout(); 380CancellationToken.None).DefaultTimeout(); 418CancellationToken.None).DefaultTimeout(); 462CancellationToken.None); 498CancellationToken.None).DefaultTimeout(); 530CancellationToken.None).DefaultTimeout(); 565CancellationToken.None).DefaultTimeout(); 602CancellationToken.None).DefaultTimeout(); 660CancellationToken.None).DefaultTimeout(); 746CancellationToken.None).DefaultTimeout(); 818CancellationToken.None); 880CancellationToken.None);

518await Task.Delay(500, CancellationToken.None);

30releaseDiscovery.Wait(CancellationToken.None);

794return await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(new TestAppHostSocket("socket.hash1"), isInScope: true, NullLogger.Instance, new ProfilingTelemetry(new ConfigurationBuilder().Build()), clientSocket, CancellationToken.None).DefaultTimeout();

44cancellationToken: CancellationToken.None).DefaultTimeout(); 73cancellationToken: CancellationToken.None).DefaultTimeout(); 109cancellationToken: CancellationToken.None).DefaultTimeout(); 139CancellationToken.None).DefaultTimeout(); 176cancellationToken: CancellationToken.None).DefaultTimeout(); 207cancellationToken: CancellationToken.None).DefaultTimeout();

684await Task.Delay(50, CancellationToken.None); 1558await prefetcher.StartAsync(CancellationToken.None).DefaultTimeout(); 1565await prefetcher.StopAsync(CancellationToken.None).DefaultTimeout(); 2102var runToken = CancellationToken.None; 3208await AppHostHelper.BuildAppHostAsync(testRunner, testInteractionService, appHostProjectFile, noRestore: false, env: null, options, workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 3882CancellationToken.None 3926CancellationToken.None 3974CancellationToken.None 4017CancellationToken.None 4061CancellationToken.None 4105CancellationToken.None 4150CancellationToken.None 4445await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None); 4491await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None); 4537await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None); 4591await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None); 4635await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None); 4679await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None); 4776await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None) 4819await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None) 4858await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None); 4904CancellationToken.None); 4951await RunCommand.CaptureAppHostLogsAsync(fileLoggerProvider, backchannel, interactionService, CancellationToken.None);

395factory, "http://localhost:18888", "browser-token", NullLogger.Instance, CancellationToken.None); 412factory, "http://localhost:18888", "browser-token", NullLogger.Instance, CancellationToken.None); 426factory, "http://localhost:18888", "wrong-token", NullLogger.Instance, CancellationToken.None); 440factory, "http://localhost:18888", "browser-token", NullLogger.Instance, CancellationToken.None); 453factory, "http://localhost:18888", "browser-token", NullLogger.Instance, CancellationToken.None); 467factory, "http://localhost:18888", "browser-token", NullLogger.Instance, CancellationToken.None); 488factory, "http://localhost:18888", "my-token", NullLogger.Instance, CancellationToken.None); 508factory, "http://localhost:18888", "my-token", NullLogger.Instance, CancellationToken.None);

93CancellationToken.None).DefaultTimeout(); 135CancellationToken.None).DefaultTimeout(); 169CancellationToken.None).DefaultTimeout(); 211CancellationToken.None).DefaultTimeout(); 252CancellationToken.None).DefaultTimeout(); 280var exitCode = await runner.BuildAsync(projectFile, noRestore: false, options, CancellationToken.None).DefaultTimeout(); 312CancellationToken.None).DefaultTimeout(); 345var exitCode = await runner.BuildAsync(projectFile, noRestore: false, new ProcessInvocationOptions(), CancellationToken.None).DefaultTimeout(); 442var exitCode = await runner.RestoreAsync(projectFile, options, CancellationToken.None).DefaultTimeout(); 479var exitCode = await runner.BuildAsync(projectFile, noRestore: false, options, CancellationToken.None).DefaultTimeout(); 508var exitCode = await runner.BuildAsync(projectFile, noRestore: true, options, CancellationToken.None).DefaultTimeout(); 537var exitCode = await runner.BuildAsync(projectFile, noRestore: false, options, CancellationToken.None).DefaultTimeout(); 578var exitCode = await runner.BuildAsync(projectFile, noRestore: false, options, CancellationToken.None).DefaultTimeout(); 610var exitCode = await runner.NewProjectAsync("aspire", "TestProject", "/tmp/test", [], options, CancellationToken.None).DefaultTimeout(); 647CancellationToken.None).DefaultTimeout(); 688CancellationToken.None).DefaultTimeout(); 733CancellationToken.None).DefaultTimeout(); 786CancellationToken.None).DefaultTimeout(); 842CancellationToken.None).DefaultTimeout(); 884var exitCode = await runner.NewProjectAsync("aspire", "TestProject", "/tmp/test", [], options, CancellationToken.None).DefaultTimeout(); 925CancellationToken.None).DefaultTimeout(); 967CancellationToken.None).DefaultTimeout(); 1014CancellationToken.None).DefaultTimeout(); 1082cancellationToken: CancellationToken.None); 1142CancellationToken.None).DefaultTimeout()); 1180CancellationToken.None).DefaultTimeout(); 1222CancellationToken.None).DefaultTimeout(); 1277CancellationToken.None 1344CancellationToken.None 1410CancellationToken.None 1481CancellationToken.None 1527var (exitCode, projects) = await runner.GetSolutionProjectsAsync(solutionFile, options, CancellationToken.None).DefaultTimeout(); 1564var exitCode = await runner.AddProjectReferenceAsync(projectFile, referencedProject, options, CancellationToken.None).DefaultTimeout(); 1611CancellationToken.None).DefaultTimeout(); 1657CancellationToken.None).DefaultTimeout(); 1692CancellationToken.None).DefaultTimeout(); 1729CancellationToken.None).DefaultTimeout(); 1771CancellationToken.None).DefaultTimeout(); 1816CancellationToken.None).DefaultTimeout(); 1868CancellationToken.None).DefaultTimeout(); 1917CancellationToken.None).DefaultTimeout(); 1965CancellationToken.None).DefaultTimeout(); 2003CancellationToken.None 2035CancellationToken.None 2078var result = await runner.GetAppHostInformationAsync(projectFile, new ProcessInvocationOptions(), CancellationToken.None); 2120var result = await runner.GetAppHostInformationAsync(projectFile, new ProcessInvocationOptions(), CancellationToken.None); 2163CancellationToken.None 2199CancellationToken.None 2284CancellationToken.None 2327CancellationToken.None 2369CancellationToken.None 2411CancellationToken.None 2458CancellationToken.None); 2521CancellationToken.None); 2576CancellationToken.None).DefaultTimeout(); 2614CancellationToken.None).DefaultTimeout(); 2653CancellationToken.None).DefaultTimeout(); 2693CancellationToken.None).DefaultTimeout(); 2730CancellationToken.None).DefaultTimeout();

41Assert.True(await child.StartAsync(CancellationToken.None)); 101Assert.True(await detachedProcess.StartAsync(CancellationToken.None)); 122await detachedProcess.WaitForExitAsync(CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(5)); 199await detachedProcess.WaitForExitAsync(CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(5)); 243Assert.True(await detachedProcess.StartAsync(CancellationToken.None)); 244await detachedProcess.WaitForExitAsync(CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(5)); 289Assert.True(await detachedProcess.StartAsync(CancellationToken.None)); 296await detachedProcess.WaitForExitAsync(CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(5)); 349Assert.True(await detachedProcess.StartAsync(CancellationToken.None)); 350await detachedProcess.WaitForExitAsync(CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(5)); 397Assert.True(await detachedProcess.StartAsync(CancellationToken.None)); 448var startTask = detachedProcess.StartAsync(CancellationToken.None);

32await Assert.ThrowsAsync<ObjectDisposedException>(() => execution.StartAsync(CancellationToken.None)); 81Assert.True(await execution.StartAsync(CancellationToken.None)); 83var exitCode = await execution.WaitForExitAsync(CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 139Assert.True(await execution.StartAsync(CancellationToken.None)); 141var exitCode = await execution.WaitForExitAsync(CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 168Assert.True(await execution.StartAsync(CancellationToken.None)); 196Assert.True(await execution.StartAsync(CancellationToken.None)); 227Assert.True(await execution.StartAsync(CancellationToken.None)); 257Assert.True(await execution.StartAsync(CancellationToken.None));

26var result = await repo.GetIncludedFilesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 66var result = await repo.GetIncludedFilesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 95var result = await repo.GetIncludedFilesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 126var result = await repo.GetIncludedFilesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout();

89interactionService.PromptForSelectionAsync("Select an item:", choices, x => x, cancellationToken: CancellationToken.None)); 101interactionService.PromptForSelectionsAsync("Select items:", choices, x => x, cancellationToken: CancellationToken.None)); 434interactionService.PromptForStringAsync("Enter value:", null, false, false, binding: null, cancellationToken: CancellationToken.None)); 447interactionService.PromptForSelectionAsync("Select an item:", choices, x => x, cancellationToken: CancellationToken.None)); 460interactionService.PromptForSelectionsAsync("Select items:", choices, x => x, cancellationToken: CancellationToken.None)); 472interactionService.PromptConfirmAsync("Confirm?", cancellationToken: CancellationToken.None)); 1304await interactionService.PromptConfirmAsync("Proceed?", PromptBinding.CreateDefault(defaultValue), cancellationToken: CancellationToken.None); 1322var result = await interactionService.PromptConfirmAsync("Proceed?", PromptBinding.CreateDefault(defaultValue), cancellationToken: CancellationToken.None); 1339var result = await interactionService.PromptConfirmAsync("Proceed?", PromptBinding.CreateDefault(defaultValue), cancellationToken: CancellationToken.None); 1356var result = await interactionService.PromptConfirmAsync("Proceed?", PromptBinding.CreateDefault(defaultValue), cancellationToken: CancellationToken.None); 1377interactionService.PromptForStringAsync("Enter value:", validator: validator, binding: binding, cancellationToken: CancellationToken.None)); 1390interactionService.PromptForStringAsync("Enter name:", required: true, binding: binding, cancellationToken: CancellationToken.None)); 1404var result = await interactionService.PromptForStringAsync("Enter value:", validator: validator, binding: binding, cancellationToken: CancellationToken.None); 1420cancellationToken: CancellationToken.None); 1438interactionService.PromptConfirmAsync("Proceed?", binding: binding, cancellationToken: CancellationToken.None)); 1450var result = await interactionService.PromptConfirmAsync("Proceed?", binding: binding, cancellationToken: CancellationToken.None); 1467var result = await interactionService.PromptConfirmAsync("Proceed?", binding: binding, cancellationToken: CancellationToken.None); 1484var result = await interactionService.PromptConfirmAsync("Proceed?", binding: binding, cancellationToken: CancellationToken.None); 1605var result = await interactionService.PromptConfirmAsync("Proceed?", binding: null, cancellationToken: CancellationToken.None); 1625interactionService.PromptForSelectionAsync("Select:", choices, x => x, binding, cancellationToken: CancellationToken.None)); 1647interactionService.PromptForSelectionsAsync("Select:", choices, x => x, binding: binding, cancellationToken: CancellationToken.None)); 1674interactionService.PromptForSelectionsAsync("Select:", visibleChoices, x => x, binding: binding, bindingChoices: bindingChoices, cancellationToken: CancellationToken.None)); 1705cancellationToken: CancellationToken.None)); 1737cancellationToken: CancellationToken.None)); 1757var result = await interactionService.PromptForSelectionAsync("Select:", choices, x => x, binding, cancellationToken: CancellationToken.None); 1775var result = await interactionService.PromptForSelectionAsync("Select:", choices, x => x, binding, cancellationToken: CancellationToken.None); 1793var result = await interactionService.PromptForSelectionsAsync("Select:", choices, x => x, binding: binding, cancellationToken: CancellationToken.None); 1866var result = await interactionService.PromptForStringAsync("Enter value:", binding: binding, cancellationToken: CancellationToken.None); 1883interactionService.PromptForSelectionAsync("Select:", choices, x => x, binding, cancellationToken: CancellationToken.None)); 1899var result = await interactionService.PromptForSelectionAsync("Select:", choices, x => x, binding, cancellationToken: CancellationToken.None); 1918var result = await interactionService.PromptForSelectionsAsync("Select:", choices, x => x, binding: binding, cancellationToken: CancellationToken.None); 1937var result = await interactionService.PromptForSelectionAsync("Select:", choices, x => x, binding, cancellationToken: CancellationToken.None); 1956var result = await interactionService.PromptForSelectionsAsync("Select:", choices, x => x, binding: binding, cancellationToken: CancellationToken.None);

134CancellationToken.None); 177CancellationToken.None); 223CancellationToken.None); 245var supported = await interactionService.SupportsMessageActionsAsync(CancellationToken.None); 261var supported = await interactionService.SupportsMessageActionsAsync(CancellationToken.None);

129var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 162var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 199var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 233var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 271var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 291var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 307var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 328var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 344var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 365var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 414var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout();

46() => tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("test-resource", "start")), CancellationToken.None).AsTask()).DefaultTimeout(); 63var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "start")), CancellationToken.None).DefaultTimeout(); 88CancellationToken.None).DefaultTimeout(); 109CancellationToken.None).DefaultTimeout(); 131() => tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "click", """[]""")), CancellationToken.None).AsTask()).DefaultTimeout(); 150() => tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "click", argumentsJson)), CancellationToken.None).AsTask()).DefaultTimeout(); 171var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("nonexistent", "start")), CancellationToken.None).DefaultTimeout(); 194var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("nonexistent", "start")), CancellationToken.None).DefaultTimeout(); 224var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "validate")), CancellationToken.None).DefaultTimeout(); 249() => tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "stop")), CancellationToken.None).AsTask()).DefaultTimeout(); 267var startResult = await tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "start")), CancellationToken.None).DefaultTimeout(); 271var stopResult = await tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "stop")), CancellationToken.None).DefaultTimeout(); 275var restartResult = await tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "restart")), CancellationToken.None).DefaultTimeout(); 290() => tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).AsTask()).DefaultTimeout(); 297() => tool.CallToolAsync(CallToolContextTestHelper.Create(partialArgs), CancellationToken.None).AsTask()).DefaultTimeout(); 320var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "generate-token")), CancellationToken.None).DefaultTimeout(); 346var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(CreateArguments("api-service", "start")), CancellationToken.None).DefaultTimeout();

23var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 58var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 90var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 133var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 157await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 162await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout();

28() => tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).AsTask()).DefaultTimeout(); 44() => tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).AsTask()).DefaultTimeout(); 66var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 101var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 135var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 165var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 194var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 226var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 260var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 292var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 326var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 361var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 399var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 436var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout();

19var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 40var result = await tool.CallToolAsync(context, CancellationToken.None).DefaultTimeout(); 56var result = await tool.CallToolAsync(context, CancellationToken.None).DefaultTimeout();

53var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 78var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 116var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout();

22() => tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).AsTask()).DefaultTimeout(); 40var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 85var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 121var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 162var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout();

30() => tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).AsTask()).DefaultTimeout(); 48() => tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).AsTask()).DefaultTimeout(); 177var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 270var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 330var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 468var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout();

149var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 255var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(), CancellationToken.None).DefaultTimeout(); 315var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 418var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout(); 510var result = await tool.CallToolAsync(CallToolContextTestHelper.Create(arguments), CancellationToken.None).DefaultTimeout();

57var descriptor = await CreateMigration(workspace).DetectAsync(MigrationContext.CurrentDirectory, CancellationToken.None); 74var descriptor = await CreateMigration(workspace).DetectAsync(MigrationContext.CurrentDirectory, CancellationToken.None); 86var descriptor = await CreateMigration(workspace).DetectAsync(MigrationContext.CurrentDirectory, CancellationToken.None); 97var descriptor = await CreateMigration(workspace).DetectAsync(MigrationContext.CurrentDirectory, CancellationToken.None); 110var descriptor = await CreateMigration(workspace).DetectAsync(new MigrationContext(new FileInfo(appHostPath)), CancellationToken.None); 212await CreateMigration(workspace).ApplyAsync(MigrationContext.CurrentDirectory, CancellationToken.None); 232await CreateMigration(workspace).ApplyAsync(new MigrationContext(new FileInfo(Path.Combine(appHostDirectory.FullName, "apphost.ts"))), CancellationToken.None); 261await CreateMigration(workspace).ApplyAsync(MigrationContext.CurrentDirectory, CancellationToken.None); 276await migration.ApplyAsync(MigrationContext.CurrentDirectory, CancellationToken.None); 280await migration.ApplyAsync(MigrationContext.CurrentDirectory, CancellationToken.None);

40var packages = await nuGetPackageCache.GetCliPackagesAsync(workspace.WorkspaceRoot, prerelease: true, nugetConfigFile: null, CancellationToken.None).DefaultTimeout(); 73var packages = await nuGetPackageCache.GetPackagesAsync(workspace.WorkspaceRoot, "Aspire.Hosting", null, prerelease: false, nugetConfigFile: null, useCache: true, CancellationToken.None).DefaultTimeout(); 112var packages = await nuGetPackageCache.GetPackagesAsync(workspace.WorkspaceRoot, "Aspire.Hosting", null, prerelease: false, nugetConfigFile: null, useCache: true, CancellationToken.None).DefaultTimeout(); 155CancellationToken.None).DefaultTimeout(); 187var packages = await nuGetPackageCache.GetPackagesAsync(workspace.WorkspaceRoot, "Aspire.Hosting", null, prerelease: false, nugetConfigFile: null, useCache: true, CancellationToken.None).DefaultTimeout(); 219var packages = await nuGetPackageCache.GetPackagesAsync(workspace.WorkspaceRoot, "Aspire.Hosting", filter: null, prerelease: false, nugetConfigFile: null, useCache: true, CancellationToken.None).DefaultTimeout(); 265CancellationToken.None); 312CancellationToken.None); 345CancellationToken.None)); 376CancellationToken.None));

239CancellationToken.None); 269CancellationToken.None)); 361CancellationToken.None); 512CancellationToken.None); 572CancellationToken.None);

40var packages = await nuGetPackageCache.GetCliPackagesAsync(workspace.WorkspaceRoot, prerelease: true, nugetConfigFile: null, CancellationToken.None).DefaultTimeout(); 76var packages = await nuGetPackageCache.GetPackagesAsync(workspace.WorkspaceRoot, "Aspire.Hosting", null, prerelease: false, nugetConfigFile: null, useCache: true, CancellationToken.None).DefaultTimeout(); 118var packages = await nuGetPackageCache.GetPackagesAsync(workspace.WorkspaceRoot, "Aspire.Hosting", null, prerelease: false, nugetConfigFile: null, useCache: true, CancellationToken.None).DefaultTimeout(); 164CancellationToken.None).DefaultTimeout(); 199var packages = await nuGetPackageCache.GetPackagesAsync(workspace.WorkspaceRoot, "Aspire.Hosting", null, prerelease: false, nugetConfigFile: null, useCache: true, CancellationToken.None).DefaultTimeout(); 233var packages = await nuGetPackageCache.GetPackagesAsync(workspace.WorkspaceRoot, "Aspire.Hosting", filter: null, prerelease: false, nugetConfigFile: null, useCache: true, CancellationToken.None).DefaultTimeout(); 285CancellationToken.None)).OrderBy(package => package.Version).ToArray();

61channel.GetTemplatePackagesAsync(workspace.WorkspaceRoot, CancellationToken.None)); 83_ = await updateNotifier.GetVersionStatusAsync(workspace.WorkspaceRoot, CancellationToken.None); 177await prefetcher.StopAsync(CancellationToken.None).DefaultTimeout(); 212await prefetcher.StartAsync(CancellationToken.None).DefaultTimeout(); 217await prefetcher.StopAsync(CancellationToken.None).DefaultTimeout(); 381await prefetcher.StartAsync(CancellationToken.None).DefaultTimeout(); 390await prefetcher.StopAsync(CancellationToken.None).DefaultTimeout(); 450await prefetcher.StartAsync(CancellationToken.None).DefaultTimeout(); 455await prefetcher.StopAsync(CancellationToken.None).DefaultTimeout(); 513await prefetcher.StartAsync(CancellationToken.None).DefaultTimeout(); 516await prefetcher.StopAsync(CancellationToken.None).DefaultTimeout();

129CancellationToken.None)); 163CancellationToken.None).DefaultTimeout()); 201var packages = (await channel.GetTemplatePackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 243CancellationToken.None).DefaultTimeout()).ToArray(); 292CancellationToken.None).DefaultTimeout()); 317CancellationToken.None).DefaultTimeout()); 371var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 419var packageIds = (await channel.GetPolyglotCompatiblePackageIdsAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()) 450var packageIds = await channel.GetPolyglotCompatiblePackageIdsAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 477var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 478var packageIds = await channel.GetPolyglotCompatiblePackageIdsAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 522var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 563var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 608var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()) 646var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 665var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 684var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 714var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 735var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 765var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray(); 796var packages = (await channel.GetIntegrationPackagesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout()).ToArray();

162var packages = (await stagingChannel.GetIntegrationPackagesAsync(tempDir, CancellationToken.None).DefaultTimeout()) 165var polyglotPackageIds = (await stagingChannel.GetPolyglotCompatiblePackageIdsAsync(tempDir, CancellationToken.None).DefaultTimeout()) 1787var templatePackages = await localChannel.GetTemplatePackagesAsync(tempDir, CancellationToken.None).DefaultTimeout(); 1834var templatePackages = await stagingChannel.GetTemplatePackagesAsync(tempDir, CancellationToken.None).DefaultTimeout(); 1886var integrationPackages = await stagingChannel.GetIntegrationPackagesAsync(tempDir, CancellationToken.None).DefaultTimeout(); 1937var templatePackages = await stagingChannel.GetTemplatePackagesAsync(tempDir, CancellationToken.None).DefaultTimeout(); 2053var integrationPackages = await localChannel.GetIntegrationPackagesAsync(tempDir, CancellationToken.None).DefaultTimeout();

32await child.StartAsync(CancellationToken.None); 61await child.StartAsync(CancellationToken.None); 101await child.StartAsync(CancellationToken.None); 144await child.StartAsync(CancellationToken.None); 179await Assert.ThrowsAsync<ObjectDisposedException>(() => child.StartAsync(CancellationToken.None));

40var result = await signaler.TryStopProcessTreeWithDcpAsync(Environment.ProcessId, startTime, includeStartTime: true, CancellationToken.None); 75CancellationToken.None); 101var result = await signaler.TryStopProcessTreeWithDcpAsync(Environment.ProcessId, ProcessStartTimeHelper.GetCurrentProcessStartTime(), includeStartTime: false, CancellationToken.None); 180CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(5)); 227CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(2)); 266CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(2)); 305CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(5));

53await using var session = await service.StartAsync(options, s_testTimeout, s_testPollInterval, CancellationToken.None); 102await using var session = await service.StartAsync(CreateOptions(workspace), s_testTimeout, s_testPollInterval, CancellationToken.None); 139() => service.StartAsync(CreateOptions(workspace), s_testTimeout, s_testPollInterval, CancellationToken.None)); 171await using var session = await service.StartAsync(CreateOptions(workspace), s_testTimeout, s_testPollInterval, CancellationToken.None); 190() => service.StartAsync(CreateOptions(workspace), s_testTimeout, s_testPollInterval, CancellationToken.None)); 212() => service.StartAsync(CreateOptions(workspace), s_testTimeout, s_testPollInterval, CancellationToken.None)); 243() => service.StartAsync(CreateOptions(workspace), s_testTimeout, s_testPollInterval, CancellationToken.None)); 270() => service.StartAsync(CreateOptions(workspace), s_testTimeout, s_testPollInterval, CancellationToken.None)); 297await session.WaitForDashboardAsync(s_testTimeout, TimeSpan.Zero, CancellationToken.None); 313() => session.WaitForDashboardAsync(s_testTimeout, s_testPollInterval, CancellationToken.None)); 333() => session.WaitForDashboardAsync(s_testTimeout, s_testPollInterval, CancellationToken.None)); 355Assert.True(await process.StartAsync(CancellationToken.None)); 398var exitCode = await session.ExportAsync(CancellationToken.None); 434var exitCode = await session.ExportAsync(CancellationToken.None); 455var exitCode = await session.ExportAsync(CancellationToken.None); 471var exitCode = await session.ExportAsync(CancellationToken.None); 488var exception = await Assert.ThrowsAsync<HttpRequestException>(() => session.ExportAsync(CancellationToken.None)); 504await Assert.ThrowsAsync<JsonException>(() => session.ExportAsync(CancellationToken.None)); 596Assert.True(process.StartAsync(CancellationToken.None).GetAwaiter().GetResult()); 623Assert.True(process.StartAsync(CancellationToken.None).GetAwaiter().GetResult());

35var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, [], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 51var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 79var result = await finder.FindCandidateFilesAsync(searchDirectory, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 96var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 114var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["apphost.ts"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 132var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["apphost.ts"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 154var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["apphost.ts"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 173var result = await finder.FindCandidateFilesAsync(searchRoot, ["apphost.ts"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 189var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["bin"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 207var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 228var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 262var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 288var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 317var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 341var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], differentlyCasedNuGetCachePath, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 366var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.AllFiles, CancellationToken.None).DefaultTimeout(); 385var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath, AppHostDiscoveryScope.AllFiles, CancellationToken.None).DefaultTimeout(); 411var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.ExplicitDirectory, CancellationToken.None).DefaultTimeout(); 427var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.ExplicitDirectory, CancellationToken.None, maxDepth: 0).DefaultTimeout(); 442var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["App/AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.ExplicitDirectory, CancellationToken.None, maxDepth: 0).DefaultTimeout(); 458var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None, maxDepth: 0).DefaultTimeout(); 475var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, patterns, nugetCachePath: null, AppHostDiscoveryScope.AllFiles, CancellationToken.None).DefaultTimeout(); 522var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["App/AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.AllFiles, CancellationToken.None).DefaultTimeout(); 548var result = await finder.FindCandidateFilesAsync(workspace.WorkspaceRoot, ["AppHost.csproj", "apphost.ts"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 576var result = await finder.FindCandidateFilesAsync(searchDirectory, ["AppHost.csproj"], nugetCachePath: null, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout();

42var info = await resolver.GetAppHostInfoAsync(projectFile, CancellationToken.None).DefaultTimeout(); 71var first = await resolver.GetAppHostInfoAsync(projectFile, CancellationToken.None).DefaultTimeout(); 72var second = await resolver.GetAppHostInfoAsync(projectFile, CancellationToken.None).DefaultTimeout(); 97var failed = await resolver.GetAppHostInfoAsync(projectFile, CancellationToken.None).DefaultTimeout(); 98var succeeded = await resolver.GetAppHostInfoAsync(projectFile, CancellationToken.None).DefaultTimeout(); 125.Select(_ => resolver.GetAppHostInfoAsync(projectFile, CancellationToken.None)) 164var uncanceledWaiter = await resolver.GetAppHostInfoAsync(projectFile, CancellationToken.None).DefaultTimeout(); 188var info = await resolver.GetAppHostInfoAsync(projectFile, CancellationToken.None).DefaultTimeout();

567var (projectFilePath, _) = await project.CreateProjectFilesAsync(packages, packageSourceOverride: overrideSource, cancellationToken: CancellationToken.None).DefaultTimeout();

40CancellationToken.None, 59CancellationToken.None, 82CancellationToken.None, 120CancellationToken.None, 136CancellationToken.None); 153CancellationToken.None); 180CancellationToken.None); 193CancellationToken.None); 400CancellationToken.None); 453CancellationToken.None); 639await execution.StartAsync(CancellationToken.None); 688await execution.StartAsync(CancellationToken.None);

68var validation = await project.ValidateAppHostAsync(ordinaryProject, CancellationToken.None); 99var validation = await project.ValidateAppHostAsync(appHostFile, CancellationToken.None); 142var validation = await project.ValidateAppHostAsync(appHostFile, CancellationToken.None); 143var version = await project.GetAspireHostingVersionAsync(appHostFile, CancellationToken.None); 176var validation = await project.ValidateAppHostAsync(appHostFile, CancellationToken.None); 208var validation = await project.ValidateAppHostAsync(appHostFile, CancellationToken.None); 355}, CancellationToken.None); 396}, CancellationToken.None); 412CancellationToken.None); 429CancellationToken.None); 497}, CancellationToken.None); 550}, CancellationToken.None); 605}, CancellationToken.None); 668}, CancellationToken.None); 712}, CancellationToken.None); 759}, CancellationToken.None); 819}, CancellationToken.None); 882}, CancellationToken.None); 940}, CancellationToken.None); 997}, CancellationToken.None); 1099}, CancellationToken.None); 1183}, CancellationToken.None); 1253}, CancellationToken.None); 1311}, CancellationToken.None); 1345}, CancellationToken.None); 1387}, CancellationToken.None); 1428}, CancellationToken.None); 1478}, CancellationToken.None); 1522}, CancellationToken.None); 1576}, CancellationToken.None); 1633}, CancellationToken.None); 1787}, CancellationToken.None); 1842}, CancellationToken.None); 1897}, CancellationToken.None); 1962}, CancellationToken.None); 2023}, CancellationToken.None); 2088}, CancellationToken.None); 2145}, CancellationToken.None); 2211}, CancellationToken.None); 2277}, CancellationToken.None); 2317}, CancellationToken.None); 2363}, CancellationToken.None); 2412}, CancellationToken.None); 2472}, CancellationToken.None); 2510}, CancellationToken.None); 2565}, CancellationToken.None); 2607}, CancellationToken.None); 3013}, CancellationToken.None);

41CancellationToken.None); 74CancellationToken.None); 100await launcher.LaunchAsync(Path.Combine(Path.GetTempPath(), "npx"), ["tsx"], new DirectoryInfo("/tmp"), new Dictionary<string, string>(), afterLaunchAsync: null, options: null, CancellationToken.None); 115await launcher.LaunchAsync(Path.Combine(Path.GetTempPath(), "npx"), [], new DirectoryInfo("/tmp"), new Dictionary<string, string>(), afterLaunchAsync: null, options: null, CancellationToken.None); 136await launcher.LaunchAsync(Path.Combine(Path.GetTempPath(), "npx"), ["tsx"], new DirectoryInfo("/tmp"), envVars, afterLaunchAsync: null, options: null, CancellationToken.None); 150var (exitCode, output) = await launcher.LaunchAsync(Path.Combine(Path.GetTempPath(), "cmd"), [], new DirectoryInfo("/tmp"), new Dictionary<string, string>(), afterLaunchAsync: null, options: null, CancellationToken.None); 167await launcher.LaunchAsync(command, [], new DirectoryInfo("/tmp"), new Dictionary<string, string>(), afterLaunchAsync: null, options: null, CancellationToken.None);

68CancellationToken.None); 76CancellationToken.None); 92await GuestAppHostProject.PruneObsoleteGeneratedFilesAsync(outputPath, ["Generated.java"], CancellationToken.None); 93await GuestAppHostProject.PruneObsoleteGeneratedFilesAsync(outputPath, ["Generated.java"], CancellationToken.None); 106var written = await GuestAppHostProject.WriteGeneratedFileAsync(filePath, "class Generated { }", preserveUnchangedFiles: true, CancellationToken.None); 121var written = await GuestAppHostProject.WriteGeneratedFileAsync(filePath, "class Generated { int x; }", preserveUnchangedFiles: true, CancellationToken.None); 133var written = await GuestAppHostProject.WriteGeneratedFileAsync(filePath, "class New { }", preserveUnchangedFiles: true, CancellationToken.None); 147var written = await GuestAppHostProject.WriteGeneratedFileAsync(filePath, "def add_redis(): ...", preserveUnchangedFiles: false, CancellationToken.None); 780() => project.UpdatePackagesAsync(context, CancellationToken.None)); 843var manifests = await repositoryUpdater.FindManifestsAsync(_workspace.WorkspaceRoot, CancellationToken.None); 845var repositoryStep = await repositoryUpdater.GetUpdateStepAsync(manifests, channel, CancellationToken.None); 890var result = await project.UpdatePackagesAsync(context, CancellationToken.None); 940var result = await project.UpdatePackagesAsync(context, CancellationToken.None); 986var result = await project.UpdatePackagesAsync(context, CancellationToken.None); 1036var result = await project.UpdatePackagesAsync(context, CancellationToken.None); 1075CancellationToken.None); 1105CancellationToken.None); 1158() => project.UpdatePackagesAsync(context, CancellationToken.None)); 1213() => project.UpdatePackagesAsync(context, CancellationToken.None)); 1263var result = await project.UpdatePackagesAsync(context, CancellationToken.None); 1334var exitCode = await project.RunAsync(context, CancellationToken.None); 1440var exitCode = await project.RunAsync(context, CancellationToken.None); 1546var exitCode = await project.PublishAsync(context, CancellationToken.None); 1673await project.UpdatePackagesAsync(context, CancellationToken.None); 1759await project.UpdatePackagesAsync(context, CancellationToken.None);

129await runtime.RunAsync(appHostFile, directory, envVars, watchMode: false, launcher, CancellationToken.None); 147await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: true, launcher, CancellationToken.None); 168var (exitCode, _) = await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: true, launcher, CancellationToken.None); 189await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 212CancellationToken.None, 242CancellationToken.None, 285await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 338CancellationToken.None, 367CancellationToken.None, 387await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: true, launcher, CancellationToken.None); 404await runtime.PublishAsync(appHostFile, directory, new Dictionary<string, string>(), ["--output", "/out"], launcher, cancellationToken: CancellationToken.None); 425await runtime.PublishAsync(appHostFile, directory, new Dictionary<string, string>(), ["--output", "/out"], launcher, cancellationToken: CancellationToken.None); 461cancellationToken: CancellationToken.None); 484cancellationToken: CancellationToken.None); 501await runtime.PublishAsync(appHostFile, directory, new Dictionary<string, string>(), null, launcher, cancellationToken: CancellationToken.None); 521await runtime.RunAsync(appHostFile, directory, envVars, watchMode: false, launcher, CancellationToken.None); 542await runtime.RunAsync(appHostFile, directory, envVars, watchMode: false, launcher, CancellationToken.None); 564await runtime.RunAsync(appHostFile, directory, envVars, watchMode: false, launcher, CancellationToken.None); 611CancellationToken.None); 644await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 663await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 681await runtime.PublishAsync(appHostFile, directory, new Dictionary<string, string>(), ["--extra", "arg"], launcher, cancellationToken: CancellationToken.None); 701await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 740CancellationToken.None); 759CancellationToken.None); 829CancellationToken.None); 861CancellationToken.None); 898CancellationToken.None); 929CancellationToken.None); 986CancellationToken.None); 1168await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1212await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1232await runtime.RunAsync(appHostFile, directory, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1246await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1262await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1278await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1300await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1323await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1348await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1370await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1399await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1423await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1464await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1489await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1533await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1561await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None); 1592await runtime.RunAsync(appHostFile, workspace.WorkspaceRoot, new Dictionary<string, string>(), watchMode: false, launcher, CancellationToken.None);

726await JavaAppHostToolchainResolver.EnsureToolchainFilesExistAsync(JavaAppHostToolchainResolver.Resolve(workspace.WorkspaceRoot), CancellationToken.None); 731await JavaAppHostToolchainResolver.EnsureToolchainFilesExistAsync(JavaAppHostToolchainResolver.Resolve(workspace.WorkspaceRoot), CancellationToken.None); 743await JavaAppHostToolchainResolver.EnsureToolchainFilesExistAsync(JavaAppHostToolchainResolver.Resolve(workspace.WorkspaceRoot), CancellationToken.None); 811CancellationToken.None); 895await JavaAppHostToolchainResolver.EnsureToolchainFilesExistAsync(resolution, CancellationToken.None);

32await PrebuiltAppHostServer.WriteIfChangedAsync(path, "<Project />", CancellationToken.None); 38await PrebuiltAppHostServer.WriteIfChangedAsync(path, "<Project />", CancellationToken.None); 49await PrebuiltAppHostServer.WriteIfChangedAsync(path, "<Project />", CancellationToken.None); 50await PrebuiltAppHostServer.WriteIfChangedAsync(path, "<Project Sdk=\"Microsoft.NET.Sdk\" />", CancellationToken.None); 72await PrebuiltAppHostServer.WriteIfChangedAsync(path, "<Project Sdk=\"Microsoft.NET.Sdk\" />", CancellationToken.None); 125var before = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 130var after = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 148var before = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 151var after = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 166var before = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 171var after = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 186var inputs = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 203var inputs = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 216var first = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 217var second = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 232var inputs = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", [], projectRefs, CancellationToken.None); 246var inputs = await PrebuiltAppHostServer.ComputeRestoreInputsAsync("<Project />", packageRefs, projectRefs, CancellationToken.None); 1197() => server.GetNuGetSourcesAsync("staging", packageSourceOverride: null, CancellationToken.None)); 1224var sources = await server.GetNuGetSourcesAsync("daily", packageSourceOverride: null, CancellationToken.None); 1345var task = (Task<TemporaryNuGetConfig?>)method.Invoke(server, [requestedChannel, packageSourceOverride, CancellationToken.None])!; 1359var task = (Task<IEnumerable<string>?>)method.Invoke(server, [requestedChannel, packageSourceOverride, CancellationToken.None])!; 2593CancellationToken.None); 2607CancellationToken.None); 2641CancellationToken.None); 2656CancellationToken.None);

43CancellationToken.None);

90CancellationToken.None).DefaultTimeout(); 119CancellationToken.None).DefaultTimeout(); 150CancellationToken.None).DefaultTimeout(); 182CancellationToken.None).DefaultTimeout(); 217CancellationToken.None).DefaultTimeout(); 247CancellationToken.None).DefaultTimeout(); 271CancellationToken.None).DefaultTimeout(); 293CancellationToken.None).DefaultTimeout(); 332CancellationToken.None); 417CancellationToken.None).DefaultTimeout(); 453CancellationToken.None).DefaultTimeout(); 482CancellationToken.None).DefaultTimeout(); 549CancellationToken.None).DefaultTimeout(); 600CancellationToken.None).DefaultTimeout(); 641CancellationToken.None).DefaultTimeout(); 671CancellationToken.None).DefaultTimeout(); 702CancellationToken.None).DefaultTimeout(); 734CancellationToken.None).DefaultTimeout(); 1015CancellationToken.None).DefaultTimeout(); 1053CancellationToken.None).DefaultTimeout(); 1089CancellationToken.None).DefaultTimeout(); 1140CancellationToken.None).DefaultTimeout(); 1193CancellationToken.None).DefaultTimeout(); 1230CancellationToken.None).DefaultTimeout(); 1271CancellationToken.None).DefaultTimeout(); 1304CancellationToken.None)).DefaultTimeout(); 1449CancellationToken.None).DefaultTimeout(); 1479CancellationToken.None).DefaultTimeout(); 1566await locator.UseOrFindAppHostProjectFileAsync(null, createSettingsFile: true, CancellationToken.None).DefaultTimeout(); 1630CancellationToken.None).DefaultTimeout(); 1700CancellationToken.None).DefaultTimeout(); 1754CancellationToken.None).DefaultTimeout(); 1794var foundAppHost = await locator.UseOrFindAppHostProjectFileAsync(null, createSettingsFile: true, CancellationToken.None).DefaultTimeout(); 1828var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 1853var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 1902var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 1929var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 1966var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 1998var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 2022var result = await projectLocator.UseOrFindAppHostProjectFileAsync(appHostFile, createSettingsFile: true, CancellationToken.None).DefaultTimeout(); 2043await projectLocator.UseOrFindAppHostProjectFileAsync(appHostFile, createSettingsFile: true, CancellationToken.None).DefaultTimeout(); 2069CancellationToken.None).DefaultTimeout(); 2098await projectLocator.UseOrFindAppHostProjectFileAsync(appHostFile, createSettingsFile: true, CancellationToken.None).DefaultTimeout(); 2114await projectLocator.UseOrFindAppHostProjectFileAsync(txtFile, createSettingsFile: true, CancellationToken.None).DefaultTimeout(); 2152var result = await projectLocator.UseOrFindAppHostProjectFileAsync(null, createSettingsFile: true, CancellationToken.None).DefaultTimeout(); 2388CancellationToken.None).DefaultTimeout(); 2423CancellationToken.None).DefaultTimeout(); 2470CancellationToken.None).DefaultTimeout(); 2515CancellationToken.None).DefaultTimeout(); 2557CancellationToken.None).DefaultTimeout(); 2598CancellationToken.None).DefaultTimeout(); 2680CancellationToken.None).DefaultTimeout(); 2822var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 2866var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 2895var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 2918var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 2939var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 2962var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 2990var foundFiles = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 3026workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 3056workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 3094workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 3134workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 3158var result = await projectLocator.UseOrFindAppHostProjectFileAsync(null, MultipleAppHostProjectsFoundBehavior.Throw, createSettingsFile: false, CancellationToken.None).DefaultTimeout(); 3188await projectLocator.UseOrFindAppHostProjectFileAsync(null, MultipleAppHostProjectsFoundBehavior.Throw, createSettingsFile: false, CancellationToken.None).DefaultTimeout(); 3212var result = await projectLocator.UseOrFindAppHostProjectFileAsync(null, MultipleAppHostProjectsFoundBehavior.Throw, createSettingsFile: false, CancellationToken.None).DefaultTimeout(); 3235await projectLocator.UseOrFindAppHostProjectFileAsync(null, MultipleAppHostProjectsFoundBehavior.Throw, createSettingsFile: false, CancellationToken.None).DefaultTimeout(); 3291await projectLocator.UseOrFindAppHostProjectFileAsync(null, MultipleAppHostProjectsFoundBehavior.Throw, createSettingsFile: false, CancellationToken.None).DefaultTimeout(); 3325var result = await projectLocator.UseOrFindAppHostProjectFileAsync(null, MultipleAppHostProjectsFoundBehavior.Throw, createSettingsFile: false, CancellationToken.None).DefaultTimeout(); 3358var result = await projectLocator.UseOrFindAppHostProjectFileAsync(null, MultipleAppHostProjectsFoundBehavior.Prompt, createSettingsFile: false, CancellationToken.None).DefaultTimeout(); 3389var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 3416var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.AllFiles, CancellationToken.None).DefaultTimeout(); 3445var found = await projectLocator.FindAppHostProjectFilesAsync(workspace.WorkspaceRoot.FullName, CancellationToken.None).DefaultTimeout(); 3476var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.AllFiles, CancellationToken.None).DefaultTimeout(); 3525var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.ExplicitDirectory, CancellationToken.None).DefaultTimeout(); 3561CancellationToken.None).DefaultTimeout(); 3596var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 3633var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 3668var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 3727var foundAppHost = await projectLocator.GetAppHostFromSettingsAsync(CancellationToken.None).DefaultTimeout(); 3754var foundAppHost = await projectLocator.GetAppHostFromSettingsAsync(CancellationToken.None).DefaultTimeout(); 3785var foundAppHost = await projectLocator.GetAppHostFromSettingsAsync(CancellationToken.None).DefaultTimeout(); 3828CancellationToken.None).DefaultTimeout(); 3863await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 3898await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 3924await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 3951await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 3976await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 4003var foundAppHost = await projectLocator.GetAppHostFromSettingsAsync(CancellationToken.None).DefaultTimeout(); 4033var foundAppHost = await projectLocator.GetAppHostFromSettingsAsync(CancellationToken.None).DefaultTimeout(); 4060var foundAppHost = await projectLocator.GetAppHostFromSettingsAsync(CancellationToken.None).DefaultTimeout(); 4087var foundAppHost = await projectLocator.GetAppHostFromSettingsAsync(CancellationToken.None).DefaultTimeout(); 4160var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 4170CancellationToken.None).DefaultTimeout(); 4210var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout(); 4243var found = await projectLocator.FindAppHostProjectsAsync(workspace.WorkspaceRoot, AppHostDiscoveryScope.DefaultFiltered, CancellationToken.None).DefaultTimeout();

31var manifests = await updater.FindManifestsAsync(workingDirectory, CancellationToken.None); 49var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 66var manifests = await updater.FindManifestsAsync(child, CancellationToken.None); 86var manifests = await updater.FindManifestsAsync(child, CancellationToken.None); 128var manifests = await updater.FindManifestsAsync(root.CreateSubdirectory("src"), CancellationToken.None); 147var manifests = await updater.FindManifestsAsync(child, CancellationToken.None); 176var manifests = await updater.FindManifestsAsync(new DirectoryInfo(alias), CancellationToken.None); 178var result = await updater.UpdateAsync(manifests, CreateChannel("13.4.0"), PromptBinding.CreateDefault(true), CancellationToken.None); 181var updated = Assert.Single(await updater.FindManifestsAsync(new DirectoryInfo(alias), CancellationToken.None)); 235var manifests = await updater.FindManifestsAsync(workingDirectory, CancellationToken.None); 237var result = await updater.UpdateAsync(manifests, channel, PromptBinding.CreateDefault(true), CancellationToken.None); 292var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 294await updater.UpdateAsync(manifests, channel, PromptBinding.CreateDefault(true), CancellationToken.None); 339var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 341var result = await updater.UpdateAsync(manifests, CreateChannel("13.4.0"), PromptBinding.CreateDefault(true), CancellationToken.None); 378var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 380await updater.UpdateAsync(manifests, CreateChannel(targetVersion, channelName), PromptBinding.CreateDefault(true), CancellationToken.None); 411var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 414updater.UpdateAsync(manifests, CreateChannel("13.5.0-preview.1", "daily"), PromptBinding.CreateDefault(true), CancellationToken.None)); 440var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 443updater.UpdateAsync(manifests, CreateChannel("13.4.0"), PromptBinding.CreateDefault(true), CancellationToken.None)); 469var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 471var result = await updater.UpdateAsync(manifests, CreateChannel("13.4.0"), PromptBinding.CreateDefault(true), CancellationToken.None); 557updater.FindManifestsAsync(root, CancellationToken.None)); 580var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 582await updater.UpdateAsync(manifests, CreateChannel("13.4.0"), PromptBinding.CreateDefault(true), CancellationToken.None); 619var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 626await updater.UpdateAsync(manifests, channel, PromptBinding.CreateDefault(true), CancellationToken.None); 710var manifests = await updater.FindManifestsAsync(root, CancellationToken.None); 711var updateStep = await updater.GetUpdateStepAsync(manifests, CreateChannel("13.4.0"), CancellationToken.None);

50var stopped = await manager.StopRunningInstanceAsync(new TestAppHostSocket(socketPath), CancellationToken.None).DefaultTimeout();

100var result = await scaffoldingService.ScaffoldAsync(context, CancellationToken.None);

45await AgentTelemetryUploader.DrainAsync(workspace.Path, lockPath, CancellationToken.None).DefaultTimeout();

601await fixture.Telemetry.StopAsync(CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(30));

598var result = await detector.CheckWindowsUserDnsDomainAsync(CancellationToken.None); 619var result = await detector.CheckWindowsUserDnsDomainAsync(CancellationToken.None); 654var result = await detector.CheckWindowsWorkplaceJoinAsync(CancellationToken.None); 691var result = await detector.CheckWindowsWorkplaceJoinAsync(CancellationToken.None); 722var result = await detector.CheckWindowsWorkplaceJoinAsync(CancellationToken.None); 877var result = await detector.CheckMacPlatformSsoAsync(CancellationToken.None); 895var result = await detector.CheckMacPlatformSsoAsync(CancellationToken.None); 942var probeResult = await detector.CheckMacPlatformSsoAsync(CancellationToken.None); 999await process.WaitForExitAsync(CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(5)); 1061var result = await detector.CheckWindowsWorkplaceJoinAsync(CancellationToken.None); 1091var result = await detector.CheckGhCliExecutableAsync(executable, CancellationToken.None); 1122var result = await detector.CheckGhCliExecutableAsync(executable, CancellationToken.None); 1145var result = await detector.CheckGitHubMembershipWithTokenResultForTestingAsync(CreateGitHubToken(1), CancellationToken.None); 1170var result = await detector.CheckGitHubMembershipWithTokenResultForTestingAsync(CreateGitHubToken(1), CancellationToken.None); 1218var result = await detector.CheckGitHubMembershipWithTokenResultForTestingAsync(CreateGitHubToken(1), CancellationToken.None); 1242var result = await detector.CheckGitHubMembershipWithTokenAsync(CreateGitHubToken(1), CancellationToken.None); 1266var result = await detector.CheckGitHubMembershipWithTokenAsync(CreateGitHubToken(1), CancellationToken.None); 1290var result = await detector.CheckGitHubMembershipWithTokenAsync(CreateGitHubToken(1), CancellationToken.None); 1319var result = await detector.CheckCopilotCliAsync(CancellationToken.None); 1346var result = await detector.CheckCopilotCliAsync(CancellationToken.None); 1375var result = await detector.CheckCopilotCliAsync(CancellationToken.None); 1390CancellationToken.None); 1401CancellationToken.None); 1418CancellationToken.None); 1434CancellationToken.None); 1451CancellationToken.None); 1467CancellationToken.None); 1502CancellationToken.None); 1539var result = InternalMicrosoftDetector.DetectVisualStudioMicrosoftTenantForTesting(store, CancellationToken.None); 1552CancellationToken.None); 1587var result = await detector.CheckCopilotCliAsync(CancellationToken.None);

58Assert.True(await service.CreateOrUpdateNuGetConfigForSourceOverrideAsync(sourceOverride, channelName: null, outputDirectory.FullName, CancellationToken.None)); 99Assert.True(await service.CreateOrUpdateNuGetConfigForSourceOverrideAsync(sourceOverride, channelName: "daily", outputDirectory.FullName, CancellationToken.None)); 143Assert.True(await service.CreateOrUpdateNuGetConfigForSourceOverrideAsync(sourceOverride, channelName: null, outputDirectory.FullName, CancellationToken.None)); 162Assert.False(await service.CreateOrUpdateNuGetConfigForSourceOverrideAsync(sourceOverride: null, channelName: "daily", workspace.WorkspaceRoot.FullName, CancellationToken.None)); 163Assert.False(await service.CreateOrUpdateNuGetConfigForSourceOverrideAsync(sourceOverride: "", channelName: "daily", workspace.WorkspaceRoot.FullName, CancellationToken.None)); 164Assert.False(await service.CreateOrUpdateNuGetConfigForSourceOverrideAsync(sourceOverride: " ", channelName: "daily", workspace.WorkspaceRoot.FullName, CancellationToken.None)); 177async () => await service.CreateOrUpdateNuGetConfigForSourceOverrideAsync(sourceOverride, channelName: null, workspace.WorkspaceRoot.FullName, CancellationToken.None)); 189await service.PromptToCreateOrUpdateNuGetConfigAsync(channelName: null, outputPath: Directory.CreateTempSubdirectory().FullName, CancellationToken.None); 190await service.PromptToCreateOrUpdateNuGetConfigAsync(channelName: "", outputPath: Directory.CreateTempSubdirectory().FullName, CancellationToken.None); 191await service.PromptToCreateOrUpdateNuGetConfigAsync(channelName: " ", outputPath: Directory.CreateTempSubdirectory().FullName, CancellationToken.None); 204Assert.False(await service.CreateOrUpdateNuGetConfigWithoutPromptAsync(channelName: null, outputPath: dir.FullName, CancellationToken.None)); 205Assert.False(await service.CreateOrUpdateNuGetConfigWithoutPromptAsync(channelName: "", outputPath: dir.FullName, CancellationToken.None)); 206Assert.False(await service.CreateOrUpdateNuGetConfigWithoutPromptAsync(channelName: " ", outputPath: dir.FullName, CancellationToken.None)); 247async () => await service.ResolveTemplatePackageAsync(query, CancellationToken.None)); 276async () => await service.ResolveTemplatePackageAsync(query, CancellationToken.None)); 314var selection = await service.ResolveTemplatePackageAsync(query, CancellationToken.None); 375await service.ResolveTemplatePackageAsync(query, CancellationToken.None); 432var selection = await service.ResolveTemplatePackageAsync(query, CancellationToken.None); 473CancellationToken.None); 531CancellationToken.None); 561async () => await service.ResolveTemplatePackageAsync(query, CancellationToken.None)); 629var selection = await service.ResolveTemplatePackageAsync(query, CancellationToken.None); 706async () => await service.ResolveTemplatePackageAsync(query, CancellationToken.None)); 747CancellationToken.None); 790CancellationToken.None); 826CancellationToken.None); 862CancellationToken.None)); 914var selection = await service.ResolveTemplatePackageAsync(query, CancellationToken.None); 952var selection = await service.ResolveTemplatePackageAsync(query, CancellationToken.None); 1017var selection = await service.ResolveTemplatePackageAsync(query, CancellationToken.None); 1068CancellationToken.None); 1120await service.PromptToCreateOrUpdateNuGetConfigAsync(channelName: "daily", outputDir.FullName, CancellationToken.None); 1158await service.PromptToCreateOrUpdateNuGetConfigAsync(channelName: "stable", outputDir.FullName, CancellationToken.None); 1203await service.PromptToCreateOrUpdateNuGetConfigAsync(channelName: "stable", outputDir.FullName, CancellationToken.None); 1260var result = await service.CreateOrUpdateNuGetConfigWithoutPromptAsync(channelName: "stable", outputDir.FullName, CancellationToken.None);

97.ApplyAsync(_terminal, CancellationToken.None)

32runner, interactionService, projectFile, telemetry, workingDirectory, "test.log", CancellationToken.None);

58await notifier.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 102await notifier.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 146await notifier.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 208await notifier.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 246await notifier.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 282await notifier.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 319await notifier.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 359await notifier.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 384await service.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout(); 403await service.CheckForCliUpdatesAsync(workspace.WorkspaceRoot, CancellationToken.None).DefaultTimeout();

31releaseCheck.Wait(CancellationToken.None);

46CancellationToken.None).ConfigureAwait(false);

609await TelemetryImportService.ImportAsync(file.Name, fileStream, CancellationToken.None);

241_ = CloseToastAfterDelayAsync(toastId, CancellationToken.None);

98var result = await ExportHelpers.GetSpanAsJsonAsync(span, _dataSource.TelemetryRepository, CancellationToken.None).ConfigureAwait(false);

106var browserThemeSettings = await _themeResolver.GetThemeSettingsAsync(CancellationToken.None).ConfigureAwait(false);

116var result = await ExportHelpers.GetTraceAsJsonAsync(trace, _dataSource.TelemetryRepository, CancellationToken.None).ConfigureAwait(false);

155=> ReadAsync(buffer.AsMemory(offset, count), CancellationToken.None).AsTask().GetAwaiter().GetResult(); 158=> WriteAsync(buffer.AsMemory(offset, count), CancellationToken.None).AsTask().GetAwaiter().GetResult();

404await ObserveTeardownAsync(send, logger).WaitAsync(s_closeTimeout, CancellationToken.None).ConfigureAwait(false);

53cancellationToken: CancellationToken.None 133cancellationToken: CancellationToken.None 176var selectedLogEntryId = (await repository.GetLogsForSpanAsync(trace.TraceId, span.SpanId, CancellationToken.None)).Single().InternalId; 186cancellationToken: CancellationToken.None 242}, CancellationToken.None); 255cancellationToken: CancellationToken.None 327}, CancellationToken.None); 348cancellationToken: CancellationToken.None

31var initialResult = await cut.InvokeAsync(() => virtualize.ItemsProvider!(new ItemsProviderRequest(0, 100, CancellationToken.None)).AsTask()); 32var refreshedResult = await cut.InvokeAsync(() => virtualize.ItemsProvider!(new ItemsProviderRequest(0, 100, CancellationToken.None)).AsTask());

128await cut.Instance.DashboardClient.SendInteractionRequestAsync(request, CancellationToken.None);

75CancellationToken.None);

998}, CancellationToken.None);

167await database.InitializeSchemaAsync(CancellationToken.None); 204database.InitializeSchemaAsync(CancellationToken.None).GetAwaiter().GetResult();

27=> InvokeAsync<TValue>(identifier, CancellationToken.None, args);

41await client.ConnectAsync(CreateWebSocketUri(frontendUri), CancellationToken.None).DefaultTimeout(); 44await client.CloseAsync(WebSocketCloseStatus.NormalClosure, "Test complete", CancellationToken.None).DefaultTimeout();

533}, cancellationToken: CancellationToken.None); 593}, cancellationToken: CancellationToken.None); 670}, cancellationToken: CancellationToken.None); 776}, cancellationToken: CancellationToken.None);

39await using var connection = await fixture.TerminalResolver.AcceptConnectionAsync(CancellationToken.None).DefaultTimeout(); 42await connection.WaitForPeerHandshakesAsync(CancellationToken.None).DefaultTimeout(); 56await connection.WaitForProducerTextAsync("Output while read-only", CancellationToken.None).DefaultTimeout(); 91Assert.Equal("other-view", await connection.ReadInputTextAsync("other-view".Length, CancellationToken.None).DefaultTimeout()); 106Assert.Equal("xallowed-paste", await connection.ReadInputTextAsync("xallowed-paste".Length, CancellationToken.None).DefaultTimeout()); 115Assert.Equal("still-active", await connection.ReadInputTextAsync("still-active".Length, CancellationToken.None).DefaultTimeout()); 118Assert.Equal("final-check", await connection.ReadInputTextAsync("final-check".Length, CancellationToken.None).DefaultTimeout()); 158Assert.Equal("x", await connection.ReadInputTextAsync(1, CancellationToken.None).DefaultTimeout()); 178Assert.Equal("xpaste", await connection.ReadInputTextAsync(6, CancellationToken.None).DefaultTimeout()); 282var connection = await fixture.TerminalResolver.AcceptConnectionAsync(CancellationToken.None).DefaultTimeout(); 283await connection.WaitForPeerHandshakesAsync(CancellationToken.None).DefaultTimeout();

71await databasePool.InitializeAsync(CancellationToken.None);

69new Uri($"wss://dashboard.example.com/api/apphost-terminal?terminalId=terminal&viewId={session.Id}"), CancellationToken.None).DefaultTimeout(); 79true, CancellationToken.None).DefaultTimeout(); 80var message = await socket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None).DefaultTimeout(); 84await socket.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "Received", CancellationToken.None).DefaultTimeout(); 191using var socket = await client.ConnectAsync(uri, CancellationToken.None).DefaultTimeout(); 192var message = await socket.ReceiveAsync(new ArraySegment<byte>(new byte[64]), CancellationToken.None).DefaultTimeout(); 199await socket.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "Received", CancellationToken.None).DefaultTimeout(); 203var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => client.ConnectAsync(uri, CancellationToken.None).DefaultTimeout()); 345var (_, subscription) = await client.SubscribeResourcesAsync(CancellationToken.None).DefaultTimeout(); 373var (_, subscription) = await client.SubscribeResourcesAsync(CancellationToken.None).DefaultTimeout(); 398await Assert.ThrowsAsync<ObjectDisposedException>(() => client.SubscribeResourcesAsync(CancellationToken.None)).DefaultTimeout(); 411_ = await client.SubscribeResourcesAsync(CancellationToken.None).DefaultTimeout(); 429var subscribeTask = client.SubscribeResourcesAsync(CancellationToken.None); 465await foreach (var batch in instance.SubscribeConsoleLogs("api", CancellationToken.None)) 489var subscription = client.SubscribeInteractionsAsync(CancellationToken.None); 516var subscription = client.SubscribeInteractionsAsync(CancellationToken.None); 541Assert.Throws<ObjectDisposedException>(() => client.SubscribeInteractionsAsync(CancellationToken.None)); 553_ = client.SubscribeInteractionsAsync(CancellationToken.None); 883CancellationToken.None).DefaultTimeout(); 901CancellationToken.None); 929await using var updates = client.SubscribeTerminalsAsync(CancellationToken.None).GetAsyncEnumerator(); 1038await using var updates = client.SubscribeTerminalsAsync(CancellationToken.None).GetAsyncEnumerator();

152await initializer.StartAsync(CancellationToken.None); 282await Assert.ThrowsAsync<InvalidOperationException>(() => dataSourcePool.InitializeAsync(CancellationToken.None)); 335await database.InitializeSchemaAsync(cancellationToken: CancellationToken.None); 375await serviceProvider.GetRequiredService<DashboardDataSourcePool>().InitializeAsync(CancellationToken.None); 494await database.InitializeSchemaAsync(cancellationToken: CancellationToken.None); 553await database.InitializeSchemaAsync(cancellationToken: CancellationToken.None); 612await database.InitializeSchemaAsync(cancellationToken: CancellationToken.None); 986await database.InitializeSchemaAsync(cancellationToken: CancellationToken.None); 1465}, cancellationToken: CancellationToken.None)).Items).Message); 1642await database.InitializeSchemaAsync(cancellationToken: CancellationToken.None); 1666dataSourcePool.InitializeAsync(CancellationToken.None).GetAwaiter().GetResult();

46var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => database.InitializeSchemaAsync(CancellationToken.None)); 57await database.InitializeSchemaAsync(cancellationToken: CancellationToken.None); 75await database.InitializeSchemaAsync(cancellationToken: CancellationToken.None);

1691CancellationToken.None);

45var subscription = await repositoryContext.Repository.SubscribeResourcesAsync(CancellationToken.None); 70var subscription = await repositoryContext.Repository.SubscribeResourcesAsync(CancellationToken.None); 120await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 159await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 168await foreach (var batch in historicalContext.Repository.GetConsoleLogs("worker", CancellationToken.None)) 205await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 234await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 264await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 273await foreach (var batch in historicalContext.Repository.GetConsoleLogs("worker", CancellationToken.None))

27var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [], CancellationToken.None); 39var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "Hello", [], CancellationToken.None); 51var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [], CancellationToken.None); 63var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [], CancellationToken.None); 76var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [], CancellationToken.None); 88var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "xyz-not-present", [], CancellationToken.None); 100var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "hello", [], CancellationToken.None); 114var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "app1", [], CancellationToken.None); 128var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "Information", [], CancellationToken.None); 148var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [fieldFilter], CancellationToken.None); 168var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [fieldFilter], CancellationToken.None); 188var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [fieldFilter], CancellationToken.None); 209var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "Hello", [fieldFilter], CancellationToken.None); 257}, CancellationToken.None);

66}, cancellationToken: CancellationToken.None); 128var logs = await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 176var logs = await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 249var logs = await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 303}, cancellationToken: CancellationToken.None); 370var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 418var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 468var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 559}, cancellationToken: CancellationToken.None); 647}, cancellationToken: CancellationToken.None); 704using var memoryStream = await exportService.ExportSelectedAsync(selectedResources, CancellationToken.None); 776using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 824using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 875using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 935using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 989using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 1054var span = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0].Spans[0]; 1107var span = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0].Spans[0]; 1108var logs = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).Items; 1168var trace = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0]; 1169var logs = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).Items; 1210var trace = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0]; 1247var logEntry = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).Items[0];

47await service.ImportAsync("logs.json", stream, CancellationToken.None); 68await Assert.ThrowsAsync<InvalidOperationException>(() => service.ImportAsync("logs.json", stream, CancellationToken.None)); 84await service.ImportAsync("logs.json", stream, CancellationToken.None); 91var logs = await repository.GetLogsAsync(GetLogsContext.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 110await service.ImportAsync("traces.json", stream, CancellationToken.None); 116var traces = await repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 134await service.ImportAsync("metrics.json", stream, CancellationToken.None); 175await service.ImportAsync("telemetry.zip", zipStream, CancellationToken.None); 218await service.ImportAsync("telemetry.zip", zipStream, CancellationToken.None); 236await service.ImportAsync("console.txt", stream, CancellationToken.None); 254await service.ImportAsync("empty.json", stream, CancellationToken.None); 272await service.ImportAsync("invalid.json", stream, CancellationToken.None); 290await service.ImportAsync("file.xml", stream, CancellationToken.None); 322var logs = await sourceRepository.GetLogsAsync(GetLogsContext.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 335await importService.ImportAsync("logs.json", stream, CancellationToken.None); 343var importedLogs = await targetRepository.GetLogsAsync(GetLogsContext.ForResourceKey(importedResources[0].ResourceKey), cancellationToken: CancellationToken.None); 375var logs = await sourceRepository.GetLogsAsync(GetLogsContext.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 410await importService.ImportAsync("logs.json", stream, CancellationToken.None); 416var importedLogs = await targetRepository.GetLogsAsync(GetLogsContext.ForResourceKey(importedResources[0].ResourceKey), cancellationToken: CancellationToken.None); 454var traces = await sourceRepository.GetTracesAsync(GetTracesRequest.ForResourceKey(resources[0].ResourceKey), cancellationToken: CancellationToken.None); 467await importService.ImportAsync("traces.json", stream, CancellationToken.None); 474var importedTraces = await targetRepository.GetTracesAsync(GetTracesRequest.ForResourceKey(importedResources[0].ResourceKey), cancellationToken: CancellationToken.None);

80database.InitializeSchemaAsync(cancellationToken: CancellationToken.None).GetAwaiter().GetResult(); 114await database.InitializeSchemaAsync(cancellationToken: CancellationToken.None); 164database.InitializeSchemaAsync(cancellationToken: CancellationToken.None).GetAwaiter().GetResult();

225public Task WriteAsync(TerminalClientFrame message) => WriteAsync(message, CancellationToken.None);

80var result = await service.GetTracesAsync(resourceNames: null, hasError: hasError, limit: null, cancellationToken: CancellationToken.None); 220var result = await service.GetTracesAsync(resourceNames: null, hasError: null, limit: 2, cancellationToken: CancellationToken.None); 241var result = await service.GetTracesAsync(resourceNames: null, hasError: null, limit: 2, cancellationToken: CancellationToken.None, search: "duration:>=50"); 269var result = await service.GetTracesAsync(resourceNames: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: "duration:>=50"); 305var result = await service.GetTracesAsync(resourceNames: null, hasError: true, limit: null, cancellationToken: CancellationToken.None, search: "duration:>=50"); 329var result = await service.GetLogsAsync(resourceNames: null, traceId: null, severity: null, limit: 2, cancellationToken: CancellationToken.None); 358var result = await service.GetLogsAsync(resourceNames: null, traceId: null, severity: null, limit: 100_000, cancellationToken: CancellationToken.None); 376var result = await service.GetLogsAsync(resourceNames: null, traceId: null, severity: null, limit: null, cancellationToken: CancellationToken.None, search: search); 392var result = await service.GetLogsAsync(resourceNames: null, traceId: null, severity: null, limit: null, cancellationToken: CancellationToken.None, search: "uppercase warning"); 412var result = await service.GetLogsAsync(resourceNames: null, traceId: null, severity: null, limit: null, cancellationToken: CancellationToken.None, search: "products"); 436var result = await service.GetTracesAsync(resourceNames: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: search); 443var allResult = await service.GetTracesAsync(resourceNames: null, hasError: null, limit: null, cancellationToken: CancellationToken.None); 463var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: "@http.method:GET"); 489var result = await service.GetTracesAsync(resourceNames: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: "@http.method:POST"); 513var result = await service.GetLogsAsync(resourceNames: null, traceId: null, severity: null, limit: null, cancellationToken: CancellationToken.None, search: "@http.method:GET"); 533var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: "duration:>50 duration:<100"); 557var result = await service.GetLogsAsync(resourceNames: null, traceId: null, severity: null, limit: null, cancellationToken: CancellationToken.None, search: "http://www.contoso.com"); 575var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: $"timestamp:>{cutoff}"); 593var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: $"timestamp:<{cutoff}"); 611var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: $"timestamp:>={cutoff}"); 629var result = await service.GetLogsAsync(resourceNames: null, traceId: null, severity: null, limit: null, cancellationToken: CancellationToken.None, search: $"timestamp:>{cutoff}"); 645var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: "timestamp:>not-a-date"); 663var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: "timestamp:>1970-01-01T00:01:30Z"); 685var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: $"timestamp:>{localString}"); 703var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: "timestamp:>1970-01-01T01:01:30+01:00"); 726var result = await service.GetSpansAsync(resourceNames: null, traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None, search: "timestamp:>=1970-01-02"); 920var result = await service.GetSpansAsync(resourceNames: ["myapp"], traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None); 955var result = await service.GetSpansAsync(resourceNames: [replica1Key], traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None); 983var result = await service.GetSpansAsync(resourceNames: ["api-1"], traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None); 1010var result = await service.GetSpansAsync(resourceNames: ["api-a-1"], traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None); 1037var result = await service.GetSpansAsync(resourceNames: ["api"], traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None); 1060var result = await service.GetSpansAsync(resourceNames: ["unique-service"], traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None); 1084var result = await service.GetSpansAsync(resourceNames: ["MYAPP"], traceId: null, hasError: null, limit: null, cancellationToken: CancellationToken.None);

73}, cancellationToken: CancellationToken.None); 185var summaries = await repositoryContext.Repository.GetLogSummariesAsync(context, cancellationToken: CancellationToken.None); 186var logs = await repositoryContext.Repository.GetLogsAsync(context, cancellationToken: CancellationToken.None); 225var latestSummaries = await repositoryContext.Repository.GetLogSummariesAsync(latestContext, cancellationToken: CancellationToken.None); 226var latestLogs = await repositoryContext.Repository.GetLogsAsync(latestContext, cancellationToken: CancellationToken.None); 266}, cancellationToken: CancellationToken.None); 276}, cancellationToken: CancellationToken.None); 286}, cancellationToken: CancellationToken.None); 323}, cancellationToken: CancellationToken.None)).Items; 380}, cancellationToken: CancellationToken.None); 432}, cancellationToken: CancellationToken.None); 680}, cancellationToken: CancellationToken.None); 778}, cancellationToken: CancellationToken.None)!; 920}, cancellationToken: CancellationToken.None); 1068}, cancellationToken: CancellationToken.None)).Items); 1076}, cancellationToken: CancellationToken.None)).Items); 1113}, cancellationToken: CancellationToken.None); 1155}, cancellationToken: CancellationToken.None)).Items); 1163}, cancellationToken: CancellationToken.None)).Items); 1224}, cancellationToken: CancellationToken.None); 1247}, cancellationToken: CancellationToken.None); 1323}, cancellationToken: CancellationToken.None); 1413}, cancellationToken: CancellationToken.None); 1478}, cancellationToken: CancellationToken.None); 1552}, cancellationToken: CancellationToken.None); 1592}, cancellationToken: CancellationToken.None); 1633}, cancellationToken: CancellationToken.None); 1674}, cancellationToken: CancellationToken.None); 1717}, cancellationToken: CancellationToken.None); 1759}, cancellationToken: CancellationToken.None); 1817}, cancellationToken: CancellationToken.None); 1879}, cancellationToken: CancellationToken.None)).Items; 1952}, cancellationToken: CancellationToken.None)).Items;

168}, cancellationToken: CancellationToken.None))!; 269}, cancellationToken: CancellationToken.None))!; 320}, cancellationToken: CancellationToken.None); 387}, cancellationToken: CancellationToken.None); 426}, cancellationToken: CancellationToken.None); 489}, cancellationToken: CancellationToken.None); 596}, cancellationToken: CancellationToken.None))!; 714}, cancellationToken: CancellationToken.None); 890}, cancellationToken: CancellationToken.None); 905}, cancellationToken: CancellationToken.None); 935}, cancellationToken: CancellationToken.None); 950}, cancellationToken: CancellationToken.None); 1035}, cancellationToken: CancellationToken.None); 1046}, cancellationToken: CancellationToken.None); 1075}, cancellationToken: CancellationToken.None); 1090}, cancellationToken: CancellationToken.None); 1191}, cancellationToken: CancellationToken.None); 1255}, cancellationToken: CancellationToken.None); 1301}, cancellationToken: CancellationToken.None); 1381}, cancellationToken: CancellationToken.None); 1450}, cancellationToken: CancellationToken.None); 1517}, cancellationToken: CancellationToken.None); 1530}, cancellationToken: CancellationToken.None); 1624}, cancellationToken: CancellationToken.None); 1668}, cancellationToken: CancellationToken.None); 1704}, cancellationToken: CancellationToken.None); 1733}, cancellationToken: CancellationToken.None); 1780}, cancellationToken: CancellationToken.None); 1830}, cancellationToken: CancellationToken.None); 1909}, cancellationToken: CancellationToken.None); 1952}, cancellationToken: CancellationToken.None); 2001}, cancellationToken: CancellationToken.None); 2068}, cancellationToken: CancellationToken.None))!; 2122}, cancellationToken: CancellationToken.None); 2230}, cancellationToken: CancellationToken.None); 2242}, cancellationToken: CancellationToken.None); 2306}, cancellationToken: CancellationToken.None); 2369}, cancellationToken: CancellationToken.None);

129var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 130var span = Assert.Single(Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(cachedResource.ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items).Spans); 312var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 318var log = Assert.Single((await historicalContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 376var trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 382var trace = Assert.Single((await historicalContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 441}, cancellationToken: CancellationToken.None); 520}, cancellationToken: CancellationToken.None);

42Assert.Empty((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).Items); 44Assert.Empty((await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).PagedResult.Items); 53Assert.Single((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).Items); 57Assert.Single((await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).PagedResult.Items); 233var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 237var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 245var resource2Logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resource2Key], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 249var resource2Traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [resource2Key], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 274var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 280var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 318var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 321var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 349var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 352var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 840var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [key1, key2], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 864}, cancellationToken: CancellationToken.None);

86}, cancellationToken: CancellationToken.None); 175var summaries = await repositoryContext.Repository.GetTraceSummariesAsync(request, cancellationToken: CancellationToken.None); 176var traces = await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None); 210var latestSummaries = await repositoryContext.Repository.GetTraceSummariesAsync(latestRequest, cancellationToken: CancellationToken.None); 211var latestTraces = await repositoryContext.Repository.GetTracesAsync(latestRequest, cancellationToken: CancellationToken.None); 228}, cancellationToken: CancellationToken.None); 306var traces = (await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items; 307var summaries = (await repositoryContext.Repository.GetTraceSummariesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items; 370}, cancellationToken: CancellationToken.None)).PagedResult.Items); 418}, cancellationToken: CancellationToken.None)).PagedResult.Items); 491}, cancellationToken: CancellationToken.None)).PagedResult.Items); 557}, cancellationToken: CancellationToken.None); 611}, cancellationToken: CancellationToken.None); 670}, cancellationToken: CancellationToken.None)).PagedResult.Items); 722}, cancellationToken: CancellationToken.None); 792}, cancellationToken: CancellationToken.None); 868}, cancellationToken: CancellationToken.None); 909}, cancellationToken: CancellationToken.None); 963}, cancellationToken: CancellationToken.None); 1031}, cancellationToken: CancellationToken.None); 1107}, cancellationToken: CancellationToken.None); 1173}, cancellationToken: CancellationToken.None); 1188}, cancellationToken: CancellationToken.None); 1255}, cancellationToken: CancellationToken.None); 1306}, cancellationToken: CancellationToken.None); 1379}, cancellationToken: CancellationToken.None); 1483}, cancellationToken: CancellationToken.None); 1552}, cancellationToken: CancellationToken.None); 1645}, cancellationToken: CancellationToken.None)).PagedResult.Items; 1710}, cancellationToken: CancellationToken.None); 1728}, cancellationToken: CancellationToken.None); 1747}, cancellationToken: CancellationToken.None); 1799}, cancellationToken: CancellationToken.None); 1814}, cancellationToken: CancellationToken.None); 1870}, cancellationToken: CancellationToken.None); 1925}, cancellationToken: CancellationToken.None); 1937}, cancellationToken: CancellationToken.None); 1976}, cancellationToken: CancellationToken.None); 2022var trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items); 2047trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items); 2072trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items); 2097trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items); 2201}, cancellationToken: CancellationToken.None); 2318}, cancellationToken: CancellationToken.None); 2396}, cancellationToken: CancellationToken.None); 2501}, cancellationToken: CancellationToken.None); 2592}, cancellationToken: CancellationToken.None); 2665}, cancellationToken: CancellationToken.None); 2760}, cancellationToken: CancellationToken.None)).PagedResult.Items); 2858}, cancellationToken: CancellationToken.None); 2926}, cancellationToken: CancellationToken.None); 2967}, cancellationToken: CancellationToken.None); 3082}, cancellationToken: CancellationToken.None)).PagedResult.Items); 3090}, cancellationToken: CancellationToken.None)).PagedResult.Items); 3172}, cancellationToken: CancellationToken.None); 3214}, cancellationToken: CancellationToken.None); 3251}, CancellationToken.None); 3291}, cancellationToken: CancellationToken.None); 3332}, cancellationToken: CancellationToken.None); 3382}, cancellationToken: CancellationToken.None); 3442}, cancellationToken: CancellationToken.None); 3500}, cancellationToken: CancellationToken.None); 3549}, cancellationToken: CancellationToken.None); 3590}, cancellationToken: CancellationToken.None); 3679}, cancellationToken: CancellationToken.None); 3739}, cancellationToken: CancellationToken.None); 3747}, cancellationToken: CancellationToken.None); 3789}, cancellationToken: CancellationToken.None); 3833}, cancellationToken: CancellationToken.None); 3853}, cancellationToken: CancellationToken.None); 3892}, cancellationToken: CancellationToken.None); 3939}, cancellationToken: CancellationToken.None); 3993}, cancellationToken: CancellationToken.None); 4048}, cancellationToken: CancellationToken.None); 4098}, cancellationToken: CancellationToken.None); 4149}, cancellationToken: CancellationToken.None); 4231}, cancellationToken: CancellationToken.None); 4290}, cancellationToken: CancellationToken.None); 4343}, cancellationToken: CancellationToken.None); 4398}, cancellationToken: CancellationToken.None); 4472}, cancellationToken: CancellationToken.None); 4498}, cancellationToken: CancellationToken.None)).PagedResult.Items); 4523}, cancellationToken: CancellationToken.None)).PagedResult.Items); 4556}, cancellationToken: CancellationToken.None)).PagedResult.Items); 4585}, cancellationToken: CancellationToken.None)).PagedResult.Items); 4624}, cancellationToken: CancellationToken.None)).PagedResult.Items); 4781}, cancellationToken: CancellationToken.None)).PagedResult.Items); 4843}, cancellationToken: CancellationToken.None)).PagedResult.Items); 4916}, cancellationToken: CancellationToken.None)).PagedResult.Items);

22var stream = await resolver.ConnectAsync("anything", 0, CancellationToken.None); 36var stream = await resolver.ConnectAsync("missing", 0, CancellationToken.None); 51var stream = await resolver.ConnectAsync("svc", 5, CancellationToken.None); 71var stream = await resolver.ConnectAsync("svc", 0, CancellationToken.None); 91var stream = await resolver.ConnectAsync("svc", 0, CancellationToken.None); 111await Assert.ThrowsAnyAsync<Exception>(() => resolver.ConnectAsync("svc", 0, CancellationToken.None));

50await client.ConnectAsync(BuildTerminalUri(useGrpc), CancellationToken.None); 72await client.ConnectAsync(BuildTerminalUri(useGrpc), CancellationToken.None); 129client.ConnectAsync(new Uri($"{DashboardScheme}://{DashboardHost}{path}"), CancellationToken.None)); 152client.ConnectAsync(new Uri($"{endpoint}&viewId={viewId}"), CancellationToken.None));

425var stdout = process.StandardOutput.ReadToEndAsync(CancellationToken.None); 426var stderr = process.StandardError.ReadToEndAsync(CancellationToken.None); 445await process.WaitForExitAsync(CancellationToken.None).WaitAsync(TimeSpan.FromSeconds(30), CancellationToken.None); 448await Task.WhenAll(stdout, stderr).WaitAsync(TimeSpan.FromSeconds(5), CancellationToken.None);

30credential.GetToken(context, CancellationToken.None);

377CancellationToken.None,

209.BuildAsync(new(applicationOperation), NullLogger.Instance, CancellationToken.None).ConfigureAwait(false); 253.BuildAsync(new(applicationOperation), NullLogger.Instance, CancellationToken.None).ConfigureAwait(false);

518await pendingDependencyLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 564await pendingDependencyLock.WaitAsync(CancellationToken.None).ConfigureAwait(false);

88CancellationToken.None,

84public override void Flush() => FlushAsync(CancellationToken.None).GetAwaiter().GetResult();

71return notificationService.WaitForDependenciesAsync(resource.Resource, CancellationToken.None);

1707completeWriterTask = Task.WhenAll(tasks).ContinueWith(_ => channel.Writer.Complete(), CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default); 1883await Task.Delay(500, CancellationToken.None).ConfigureAwait(false); 1904}, CancellationToken.None);

785}, CancellationToken.None);

109=> ReadAsync(buffer.AsMemory(offset, count), CancellationToken.None).AsTask().GetAwaiter().GetResult(); 112=> WriteAsync(buffer.AsMemory(offset, count), CancellationToken.None).AsTask().GetAwaiter().GetResult();

603var result = await reader.ReadAsync(CancellationToken.None).ConfigureAwait(false);

369CancellationToken.None,

104CancellationToken.None); 143}, CancellationToken.None);

220await Reporter.CompleteStepAsync(this, completionText, finalState, enableMarkdown: false, cancellationToken: CancellationToken.None).ConfigureAwait(false);

91await CompleteAsync(cancellationToken: CancellationToken.None).ConfigureAwait(false);

1441var stoppingToken = serviceProvider.GetService<IHostApplicationLifetime>()?.ApplicationStopping ?? CancellationToken.None; 1470var stoppingToken = serviceProvider.GetService<IHostApplicationLifetime>()?.ApplicationStopping ?? CancellationToken.None; 1534var canceledToken = CancellationToken.None; 1576await RefreshCommandStatesAsync(queuedOperation.Model, CancellationToken.None).ConfigureAwait(false); 1623var stoppingToken = serviceProvider.GetService<IHostApplicationLifetime>()?.ApplicationStopping ?? CancellationToken.None;

621var canceledStateSection = await deploymentStateManager.AcquireSectionAsync(sectionName, CancellationToken.None).ConfigureAwait(false); 624await deploymentStateManager.SaveSectionAsync(canceledStateSection, CancellationToken.None).ConfigureAwait(false); 671var statePersistenceCancellationToken = context.ExecutionContext.IsRunMode ? CancellationToken.None : cancellationToken; 1297await deployments.CancelAsync(deploymentName, CancellationToken.None).ConfigureAwait(false);

1457CancellationToken.None);

144provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 180provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 214provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 261provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 300await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 335await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 369await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 399await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 433await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 483await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 520var exception = await Assert.ThrowsAsync<AzureProvisioningFailureException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 592var exception = await Assert.ThrowsAsync<AzureProvisioningFailureException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 673await Assert.ThrowsAsync<AzureProvisioningFailureException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 747await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 781await Assert.ThrowsAsync<RequestFailedException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 818await Assert.ThrowsAsync<RequestFailedException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 836var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 838await deploymentStateManager.SaveSectionAsync(section, CancellationToken.None); 852var reused = await provisioner.ConfigureResourceAsync(resource, CancellationToken.None); 870var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 876await deploymentStateManager.SaveSectionAsync(section, CancellationToken.None); 888var reused = await provisioner.ConfigureResourceAsync(resource, CancellationToken.None); 906var azureSection = await deploymentStateManager.AcquireSectionAsync("Azure", CancellationToken.None); 912await deploymentStateManager.SaveSectionAsync(azureSection, CancellationToken.None); 914var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 919await deploymentStateManager.SaveSectionAsync(section, CancellationToken.None); 931var reused = await provisioner.ConfigureResourceAsync(resource, CancellationToken.None); 957var azureSection = await deploymentStateManager.AcquireSectionAsync("Azure", CancellationToken.None); 963await deploymentStateManager.SaveSectionAsync(azureSection, CancellationToken.None); 965var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 970await deploymentStateManager.SaveSectionAsync(section, CancellationToken.None); 982var reused = await provisioner.ConfigureResourceAsync(resource, CancellationToken.None); 999var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 1001await deploymentStateManager.SaveSectionAsync(section, CancellationToken.None); 1018await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 1020section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 1033var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 1035await deploymentStateManager.SaveSectionAsync(section, CancellationToken.None); 1051await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 1053section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 1080await Assert.ThrowsAsync<RequestFailedException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 1082var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 1175await Assert.ThrowsAsync<AzureProvisioningFailureException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 1291await Assert.ThrowsAsync<AzureProvisioningFailureException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 1332await Assert.ThrowsAsync<OperationCanceledException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 1337var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 1365await Assert.ThrowsAsync<OperationCanceledException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 1370var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 1398await Assert.ThrowsAsync<OperationCanceledException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 1402var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 1429await provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None); 1462provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 1491var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => provisioner.GetOrCreateResourceAsync(resource, context, CancellationToken.None)); 1495var section = await deploymentStateManager.AcquireSectionAsync("Azure:Deployments:storage2", CancellationToken.None); 1508var result = await bicepExecutor.CompileBicepToArmAsync("test.bicep", CancellationToken.None); 1546var token = credential.GetToken(requestContext, CancellationToken.None); 1564var token = await credential.GetTokenAsync(requestContext, CancellationToken.None); 1590var result = await provisioner.ReconcileDeploymentStateAsync(resource, context, CancellationToken.None); 1623var result = await provisioner.ReconcileDeploymentStateAsync(resource, context, CancellationToken.None); 1648var result = await provisioner.ReconcileDeploymentStateAsync(resource, context, CancellationToken.None); 1674var result = await provisioner.ReconcileDeploymentStateAsync(resource, context, CancellationToken.None); 1700var result = await provisioner.ReconcileDeploymentStateAsync(resource, context, CancellationToken.None); 1729provisioner.ReconcileDeploymentStateAsync(resource, context, CancellationToken.None)); 1754provisioner.ReconcileDeploymentStateAsync(resource, context, CancellationToken.None)); 1785var result = await provisioner.ReconcileDeploymentStateAsync(resource, context, CancellationToken.None);

3250CancellationToken.None);

279var cs = await csExpr.GetValueAsync(CancellationToken.None); 300var cs = await csExpr.GetValueAsync(CancellationToken.None); 318await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 352await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 703CancellationToken = CancellationToken.None 736CancellationToken = CancellationToken.None 771CancellationToken = CancellationToken.None 1234() => healthCheckService.CheckHealthAsync(r => r.Name == "cosmos_check", CancellationToken.None));

360CancellationToken = CancellationToken.None, 414CancellationToken = CancellationToken.None, 516var outputTask = storage.GetOutput("blobEndpoint").GetValueAsync(CancellationToken.None).AsTask(); 655await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 705await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 740await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 752CancellationToken = CancellationToken.None, 787await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 833CancellationToken = CancellationToken.None, 899await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 917CancellationToken = CancellationToken.None, 1174await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1186CancellationToken = CancellationToken.None, 1232await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1250CancellationToken = CancellationToken.None, 1293await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1311CancellationToken = CancellationToken.None, 1355await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1372CancellationToken = CancellationToken.None, 1411await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1413var provisioningTask = controller.EnsureProvisionedAsync(model, CancellationToken.None); 1483await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1490var provisioningTask = controller.EnsureProvisionedAsync(model, CancellationToken.None); 1507CancellationToken = CancellationToken.None, 1544await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1546var activeReprovisionTask = controller.ReprovisionResourceAsync(model, storage.Resource.Name, CancellationToken.None); 1565CancellationToken = CancellationToken.None, 1603await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1605var activeReprovisionTask = controller.ReprovisionResourceAsync(model, storage1.Resource.Name, CancellationToken.None); 1616CancellationToken = CancellationToken.None, 1628CancellationToken = CancellationToken.None, 1659await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1697await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1712CancellationToken = CancellationToken.None, 1764await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1796CancellationToken = CancellationToken.None, 1867await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1890CancellationToken = CancellationToken.None, 1939await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 1961CancellationToken = CancellationToken.None, 2018await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2039CancellationToken = CancellationToken.None, 2053CancellationToken = CancellationToken.None, 2085await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2118CancellationToken = CancellationToken.None, 2163await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2182CancellationToken = CancellationToken.None, 2224await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2236CancellationToken = CancellationToken.None, 2285await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2296CancellationToken = CancellationToken.None, 2364await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2373CancellationToken = CancellationToken.None, 2387CancellationToken = CancellationToken.None, 2441await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2450CancellationToken = CancellationToken.None, 2467CancellationToken = CancellationToken.None, 2529await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2532var provisioningTask = controller.EnsureProvisionedAsync(model, CancellationToken.None); 2548CancellationToken = CancellationToken.None, 2586await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2594CancellationToken = CancellationToken.None, 2638await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2647CancellationToken = CancellationToken.None, 2661CancellationToken = CancellationToken.None, 2702await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2714CancellationToken = CancellationToken.None, 2776await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2787CancellationToken = CancellationToken.None, 2831await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2840CancellationToken = CancellationToken.None, 2891await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2900CancellationToken = CancellationToken.None, 2935await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 2961CancellationToken = CancellationToken.None, 3007await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3031CancellationToken = CancellationToken.None, 3074await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3092CancellationToken = CancellationToken.None, 3133await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3161CancellationToken = CancellationToken.None, 3199await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3218CancellationToken = CancellationToken.None, 3263await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3281CancellationToken = CancellationToken.None, 3328await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3352CancellationToken = CancellationToken.None, 3407CancellationToken = CancellationToken.None, 3447CancellationToken = CancellationToken.None, 3521CancellationToken = CancellationToken.None, 3569CancellationToken = CancellationToken.None, 3625CancellationToken = CancellationToken.None, 3659await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3700await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3747await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3772CancellationToken = CancellationToken.None, 3804await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3841await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3851CancellationToken = CancellationToken.None, 3909await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 3923CancellationToken = CancellationToken.None, 3989await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 4003CancellationToken = CancellationToken.None, 4068await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 4077CancellationToken = CancellationToken.None, 4119await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 4129CancellationToken = CancellationToken.None, 4166await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 4175CancellationToken = CancellationToken.None, 4212await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 4221CancellationToken = CancellationToken.None, 4279await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 4528CancellationToken = CancellationToken.None, 4580CancellationToken = CancellationToken.None, 4627CancellationToken = CancellationToken.None, 4675CancellationToken = CancellationToken.None, 4713var reprovisionTask = controller.EnsureProvisionedAsync(model, CancellationToken.None); 4794await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 4801var provisioningTask = controller.EnsureProvisionedAsync(model, CancellationToken.None); 4813CancellationToken = CancellationToken.None, 5030CancellationToken = CancellationToken.None, 5202CancellationToken.None);

271await context.WriteModelAsync(model, environment, CancellationToken.None); 301await context.WriteModelAsync(model, environment, CancellationToken.None);

84hb.Configuration["ConnectionStrings:hub"] = await eventHub.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 90hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 136hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 142hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None) + $";EntityPath={hubName};"; 353var configFiles = await configAnnotation.Callback(new ContainerFileSystemCallbackContext { Model = eventHubsEmulatorResource, Services = app.Services }, CancellationToken.None); 410var configFiles = await configAnnotation.Callback(new ContainerFileSystemCallbackContext { Model = eventHubsEmulatorResource, Services = app.Services }, CancellationToken.None); 480var configFiles = await configAnnotation.Callback(new ContainerFileSystemCallbackContext { Model = eventHubsEmulatorResource, Services = app.Services }, CancellationToken.None);

65Assert.Equal($"localhost:12455,password={await redisResource.PasswordParameter.GetValueAsync(CancellationToken.None)}{sslArg}", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 99Assert.Equal($"localhost:12455,password=p@ssw0rd1", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 103Assert.Equal("localhost", await redis.Resource.HostName.GetValueAsync(CancellationToken.None)); 106Assert.Equal("p@ssw0rd1", await redis.Resource.Password.GetValueAsync(CancellationToken.None)); 158var hostValue = await redis.Resource.HostName.GetValueAsync(CancellationToken.None); 161var passwordValue = await redis.Resource.Password.GetValueAsync(CancellationToken.None);

62await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 134Assert.StartsWith("Host=localhost;Port=12455;Username=postgres;Password=", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 136var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 140var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 192Assert.Equal("Host=localhost;Port=12455;Username=user1;Password=p@ssw0rd1", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 196Assert.Equal("localhost", await postgres.Resource.Host.GetValueAsync(CancellationToken.None)); 199Assert.Equal("12455", await postgres.Resource.Port.GetValueAsync(CancellationToken.None)); 202Assert.Equal("localhost:12455", await postgres.Resource.HostName.GetValueAsync(CancellationToken.None)); 205Assert.Equal("user1", await postgres.Resource.UserName.GetValueAsync(CancellationToken.None)); 208Assert.Equal("p@ssw0rd1", await postgres.Resource.Password.GetValueAsync(CancellationToken.None)); 210var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 213var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 247Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 248Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1;Database=db1", await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 249Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1;Database=db2Name", await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 329var hostValue = await postgres.Resource.HostName.GetValueAsync(CancellationToken.None); 332var userValue = await postgres.Resource.UserName.GetValueAsync(CancellationToken.None); 336var passwordValue = await postgres.Resource.Password.GetValueAsync(CancellationToken.None);

60await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 108Assert.Equal($"localhost:12455,password={redisResource.PasswordParameter.Value}", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 143Assert.Equal($"localhost:12455,password=p@ssw0rd1", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 147Assert.Equal("localhost:12455", await redis.Resource.HostName.GetValueAsync(CancellationToken.None)); 150Assert.Equal("p@ssw0rd1", await redis.Resource.Password.GetValueAsync(CancellationToken.None)); 202var hostValue = await redis.Resource.HostName.GetValueAsync(CancellationToken.None); 205var passwordValue = await redis.Resource.Password.GetValueAsync(CancellationToken.None);

752CancellationToken.None);

67await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None); 85await preparer.OnBeforeStartAsync(new BeforeStartEvent(app.Services, model), CancellationToken.None);

542CancellationToken.None); 583CancellationToken.None); 599CancellationToken.None); 603CancellationToken.None); 652var sandboxes = await client.ListSandboxesAsync(scope, "aspire-resource=site-container", CancellationToken.None); 653var diskImages = await client.ListDiskImagesAsync(scope, "aspire-resource=site-container", CancellationToken.None); 684CancellationToken.None); 1054CancellationToken.None); 1086CancellationToken.None); 1124CancellationToken.None); 1193CancellationToken.None); 1240CancellationToken.None); 1317CancellationToken.None); 1342CancellationToken.None)); 1391CancellationToken.None); 1413CancellationToken.None); 1437CancellationToken.None)); 1462CancellationToken.None)); 1486CancellationToken.None)); 1509CancellationToken.None)); 1535CancellationToken.None)); 1561CancellationToken.None)); 1584CancellationToken.None)); 1630CancellationToken.None)); 1643await client.DeleteSandboxAsync(scope, "sandbox-1", CancellationToken.None); 1644await client.DeleteDiskImageAsync(scope, "disk-1", CancellationToken.None); 1649CancellationToken.None); 1667CancellationToken.None)); 1690CancellationToken.None)); 1709CancellationToken.None); 1785CancellationToken.None); 1836CancellationToken.None); 1878CancellationToken.None); 1942CancellationToken.None); 1983CancellationToken.None); 2939CancellationToken.None); 2948await stateManager.SaveSectionAsync(state, CancellationToken.None); 2955CancellationToken.None); 2990CancellationToken.None); 3027CancellationToken.None); 3182CancellationToken.None); 3225CancellationToken.None); 3231await stateManager.SaveSectionAsync(state, CancellationToken.None); 3237CancellationToken.None); 3270CancellationToken.None); 3301CancellationToken.None); 3334CancellationToken.None);

132hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 370var configFiles = await configAnnotation.Callback(new ContainerFileSystemCallbackContext { Model = serviceBusEmulatorResource, Services = app.Services }, CancellationToken.None); 465var configFiles = await configAnnotation.Callback(new ContainerFileSystemCallbackContext { Model = serviceBusEmulatorResource, Services = app.Services }, CancellationToken.None); 517var configFiles = await configAnnotation.Callback(new ContainerFileSystemCallbackContext { Model = serviceBusEmulatorResource, Services = app.Services }, CancellationToken.None); 573var configFiles = await configAnnotation.Callback(new ContainerFileSystemCallbackContext { Model = serviceBusEmulatorResource, Services = app.Services }, CancellationToken.None); 830hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None);

31var connectionString = await connectionStringExpr.GetValueAsync(CancellationToken.None);

93var serverConnectionString = await sql.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 97var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 101var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 105var db3ConnectionString = await db3.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 159var serverConnectionString = await sql.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 162var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 165var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 168var db3ConnectionString = await db3.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None);

178hb.Configuration[$"ConnectionStrings:{blobsResourceName}"] = await blobs.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 179hb.Configuration[$"ConnectionStrings:{blobContainerName}"] = await container.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 180hb.Configuration[$"ConnectionStrings:{queuesResourceName}"] = await queues.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 181hb.Configuration[$"ConnectionStrings:{queueName}"] = await queue.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 229hb.Configuration["ConnectionStrings:BlobConnection"] = await blobs.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 269hb.Configuration["ConnectionStrings:QueueConnection"] = await queues.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None);

48CancellationToken.None); 83var locations = await armClient.GetAvailableLocationsAsync(SubscriptionId, CancellationToken.None); 105await foreach (var operation in armClient.GetDeploymentOperationsAsync(RootDeploymentId, recursive: true, CancellationToken.None)) 130await foreach (var resourceId in armClient.GetDeploymentTargetResourceIdsAsync(RootDeploymentId, CancellationToken.None)) 154var deployment = await armClient.GetDeploymentAsync(RootDeploymentId, CancellationToken.None); 171await armClient.DeleteResourceAsync(KeyVaultResourceId, cancellationToken: CancellationToken.None); 172var purged = await armClient.PurgeDeletedKeyVaultAsync(KeyVaultResourceId, "westus2", CancellationToken.None); 196var purged = await armClient.PurgeDeletedKeyVaultAsync(KeyVaultResourceId, "ukwest", CancellationToken.None); 217var deleteTask = armClient.DeleteResourceAsync(KeyVaultResourceId, cancellationToken: CancellationToken.None); 227var purgeTask = armClient.PurgeDeletedKeyVaultAsync(KeyVaultResourceId, "westus2", CancellationToken.None); 255var deleteTask = armClient.DeleteResourceAsync(KeyVaultResourceId, cancellationToken: CancellationToken.None); 277var purgeTask = armClient.PurgeDeletedKeyVaultAsync(KeyVaultResourceId, "westus2", CancellationToken.None);

422CancellationToken.None); 454CancellationToken.None); 482CancellationToken.None); 500CancellationToken.None);

46var context = await provider.CreateProvisioningContextAsync(CancellationToken.None); 85() => provider.CreateProvisioningContextAsync(CancellationToken.None)); 121() => provider.CreateProvisioningContextAsync(CancellationToken.None)); 136var azureSection = await deploymentStateManager.AcquireSectionAsync("Azure", CancellationToken.None); 141await deploymentStateManager.SaveSectionAsync(azureSection, CancellationToken.None); 154var context = await provider.CreateProvisioningContextAsync(CancellationToken.None); 186() => provider.CreateProvisioningContextAsync(CancellationToken.None)); 214var context = await provider.CreateProvisioningContextAsync(CancellationToken.None); 246var context = await provider.CreateProvisioningContextAsync(CancellationToken.None); 277var context = await provider.CreateProvisioningContextAsync(CancellationToken.None); 309var context = await provider.CreateProvisioningContextAsync(CancellationToken.None); 341var ensureTask = provider.EnsureProvisioningOptionsAsync(forcePrompt: true, CancellationToken.None); 390CancellationToken = CancellationToken.None, 400await provider.PersistProvisioningOptionsAsync(CancellationToken.None); 402var context = await provider.CreateProvisioningContextAsync(CancellationToken.None); 436var ensureTask = provider.EnsureProvisioningOptionsAsync(forcePrompt: true, CancellationToken.None); 446CancellationToken = CancellationToken.None, 456CancellationToken = CancellationToken.None, 497var ensureTask = provider.EnsureProvisioningOptionsAsync(forcePrompt: true, CancellationToken.None); 542CancellationToken = CancellationToken.None, 551CancellationToken = CancellationToken.None, 561await provider.PersistProvisioningOptionsAsync(CancellationToken.None); 563var context = await provider.CreateProvisioningContextAsync(CancellationToken.None); 599var context = await provider.CreateProvisioningContextAsync(CancellationToken.None); 638var ensureTask = provider.EnsureProvisioningOptionsAsync(forcePrompt: true, CancellationToken.None); 684var ensureTask = provider.EnsureProvisioningOptionsAsync(forcePrompt: true, CancellationToken.None); 727var ensureTask = provider.EnsureProvisioningOptionsAsync(forcePrompt: true, CancellationToken.None); 745CancellationToken = CancellationToken.None, 785var ensureTask = provider.EnsureProvisioningOptionsAsync(forcePrompt: true, CancellationToken.None); 828var ensureTask = provider.EnsureProvisioningOptionsAsync(forcePrompt: true, CancellationToken.None);

84var token = await context.Credential.GetTokenAsync(requestContext, CancellationToken.None);

272CancellationToken = CancellationToken.None, 593CancellationToken.None);

37CancellationToken.None, 70CancellationToken.None,

41var result = await EndpointsManifestTransformer.PrefixEndpointsAssetFileAsync(manifestPath, "store", CancellationToken.None); 66var result = await EndpointsManifestTransformer.PrefixEndpointsAssetFileAsync(manifestPath, "store", CancellationToken.None); 97var result = await EndpointsManifestTransformer.PrefixEndpointsAssetFileAsync(manifestPath, "store", CancellationToken.None); 121var result = await EndpointsManifestTransformer.PrefixEndpointsAssetFileAsync(manifestPath, "store", CancellationToken.None); 192manifests, outputPath, Microsoft.Extensions.Logging.Abstractions.NullLogger.Instance, CancellationToken.None); 256manifests, outputPath, Microsoft.Extensions.Logging.Abstractions.NullLogger.Instance, CancellationToken.None);

324CancellationToken = CancellationToken.None,

128var lockAcquired = await TryWaitForLockAsync(CancellationToken.None).ConfigureAwait(false);

261await resourceState.Lock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 283await session.StopAsync(CancellationToken.None).ConfigureAwait(false); 327await resourceState.Lock.WaitAsync(CancellationToken.None).ConfigureAwait(false);

189await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 457await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 471await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false);

34CancellationToken.None); 44CancellationToken.None, 70CancellationToken.None); 72var enableDiscoveryTask = connection.EnableTargetDiscoveryAsync(CancellationToken.None);

111CancellationToken = CancellationToken.None 118CancellationToken = CancellationToken.None 125CancellationToken = CancellationToken.None 164CancellationToken = CancellationToken.None

27CancellationToken.None, 50CancellationToken.None, 53var createTargetTask = connection.CreateTargetAsync(CancellationToken.None); 54var attachToTargetTask = connection.AttachToTargetAsync("target-1", CancellationToken.None); 109await pair.ServerSocket.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "Done", CancellationToken.None).DefaultTimeout(); 121CancellationToken.None, 124var captureTask = connection.CaptureScreenshotAsync("target-session-1", CancellationToken.None); 146await pair.ServerSocket.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "Done", CancellationToken.None).DefaultTimeout(); 167var createTargetTask = connection.CreateTargetAsync(CancellationToken.None); 226var result = await firstConnection.CreateTargetAsync(CancellationToken.None); 274await Assert.ThrowsAsync<InvalidOperationException>(() => failingConnection.CreateTargetAsync(CancellationToken.None)); 352var result = await socket.ReceiveAsync(buffer, CancellationToken.None).DefaultTimeout(); 368return socket.SendAsync(Encoding.UTF8.GetBytes(text), WebSocketMessageType.Text, endOfMessage: true, CancellationToken.None);

52CancellationToken.None).GetAwaiter().GetResult();

80var firstLease = await registry.AcquireAsync(configuration, CancellationToken.None); 81var secondLease = await registry.AcquireAsync(configuration, CancellationToken.None); 120var lease = await registry.AcquireAsync(configuration, CancellationToken.None); 150CancellationToken.None); 155CancellationToken.None)); 183CancellationToken.None); 195CancellationToken.None); 269CancellationToken.None); 271var metadata = await discovery.TryReadAndValidateAsync(identity, profileDirectoryName: "Default", CancellationToken.None); 298CancellationToken.None); 334var metadata = await discovery.TryReadAndValidateAsync(identity, profileDirectoryName: null, CancellationToken.None); 362CancellationToken.None); 365discovery.TryReadAndValidateAsync(identity, profileDirectoryName: "Default", CancellationToken.None)); 557CancellationToken.None));

66CancellationToken.None); 120CancellationToken.None); 160CancellationToken.None); 162var result = await session.CaptureScreenshotAsync(CancellationToken.None); 190CancellationToken.None); 192var captureTask = session.CaptureScreenshotAsync(CancellationToken.None); 232CancellationToken.None); 306CancellationToken.None);

128var lockAcquired = await TryWaitForLockAsync(CancellationToken.None).ConfigureAwait(false);

261await resourceState.Lock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 283await session.StopAsync(CancellationToken.None).ConfigureAwait(false); 327await resourceState.Lock.WaitAsync(CancellationToken.None).ConfigureAwait(false);

189await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 457await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 471await _connectionLock.WaitAsync(CancellationToken.None).ConfigureAwait(false);

3010.BuildApiModel(combinedPackage, combinedAssemblies, CancellationToken.None); 3012.BuildApiModel(combinedPackage, combinedAssemblies, CancellationToken.None); 3108CancellationToken.None);

824CancellationToken = CancellationToken.None 857CancellationToken = CancellationToken.None

51}, this, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

33var context = new RequiredCommandValidationContext("thepath", services, CancellationToken.None);

569CancellationToken = CancellationToken.None, 621CancellationToken = CancellationToken.None, 669CancellationToken = CancellationToken.None,

114var files = await a.Callback(new() { Model = serviceResource.TargetResource, Services = executionContext.Services }, CancellationToken.None).ConfigureAwait(false);

145CancellationToken.None); 202CancellationToken.None));

146CancellationToken.None, 167CancellationToken.None, 193CancellationToken.None); 202CancellationToken.None);

865CancellationToken.None);

163await s_managerLock.WaitAsync(CancellationToken.None).ConfigureAwait(false); 764return new(FoundryLocalService.StopAsync(CancellationToken.None));

318}, CancellationToken.None);

320}, CancellationToken.None);

20.ReconcileAsync(definition, CancellationToken.None); 38.ReconcileAsync(definition, CancellationToken.None); 57.ReconcileAsync(definition, "2", CancellationToken.None)); 81.ReconcileAsync(definition, CancellationToken.None)); 107.ReconcileAsync(definition, CancellationToken.None); 130.ReconcileAsync(definition, CancellationToken.None)); 152.ReconcileAsync(definition, CancellationToken.None); 179.ReconcileAsync(definition, CancellationToken.None)); 211.ReconcileAsync(definition, CancellationToken.None)); 239.ReconcileAsync(definition, CancellationToken.None)); 266.ReconcileAsync(definition, CancellationToken.None)); 294.ReconcileAsync(definition, CancellationToken.None)); 304var firstTool = await new FoundryToolboxWebSearchToolDefinition("first").ResolveAsync(CancellationToken.None); 305var secondTool = await new FoundryToolboxWebSearchToolDefinition("second").ResolveAsync(CancellationToken.None); 333.ResolveAsync(CancellationToken.None); 335.ResolveAsync(CancellationToken.None); 339.ResolveAsync(CancellationToken.None); 350.ResolveAsync(CancellationToken.None); 364var first = await new FoundryToolboxWebSearchToolDefinition("search").ResolveAsync(CancellationToken.None); 365var second = await new FoundryToolboxWebSearchToolDefinition("search").ResolveAsync(CancellationToken.None); 384.ResolveAsync(CancellationToken.None); 389.ResolveAsync(CancellationToken.None); 400var tool = await new FoundryToolboxWebSearchToolDefinition("search").ResolveAsync(CancellationToken.None); 415var tool = await new FoundryToolboxWebSearchToolDefinition("search").ResolveAsync(CancellationToken.None); 441.ValidateAsync("field-tools", version: null, CancellationToken.None); 462.ValidateAsync("field-tools", "2", CancellationToken.None); 472.ValidateAsync("field-tools", version: null, CancellationToken.None)); 491.ValidateAsync("field-tools", "2", CancellationToken.None)); 499.ResolveAsync(CancellationToken.None);

429CancellationToken.None); 596CancellationToken.None); 623CancellationToken.None); 646CancellationToken.None); 689CancellationToken.None); 721CancellationToken.None); 744CancellationToken.None);

602CancellationToken.None);

333var projectTool = (await tool.ResolveAsync(CancellationToken.None)).Tool; 350var projectTool = (await tool.ResolveAsync(CancellationToken.None)).Tool; 381var projectTool = (await def.ResolveAsync(CancellationToken.None)).Tool; 425CancellationToken.None); 470CancellationToken.None); 488var projectTool = (await def.ResolveAsync(CancellationToken.None)).Tool; 521var projectTool = (await definition.ResolveAsync(CancellationToken.None)).Tool; 561var projectTool = (await definition.ResolveAsync(CancellationToken.None)).Tool; 642async () => await def.ResolveAsync(CancellationToken.None)); 655async () => await def.ResolveAsync(CancellationToken.None)); 667async () => await def.ResolveAsync(CancellationToken.None)); 682async () => await def.ResolveAsync(CancellationToken.None)); 938CancellationToken.None)); 947return new PipelineContext(model, execContext, app.Services, NullLogger.Instance, CancellationToken.None);

64await process.WaitForExitAsync(CancellationToken.None);

748CancellationToken.None)); 767CancellationToken.None)); 794CancellationToken.None); 834await process.WaitForExitAsync(CancellationToken.None); 855CancellationToken.None)); 1363CancellationToken.None);

2742await process.WaitForExitAsync(CancellationToken.None);

265CancellationToken.None);

583CancellationToken = CancellationToken.None 643CancellationToken = CancellationToken.None 695CancellationToken = CancellationToken.None 741CancellationToken = CancellationToken.None 793CancellationToken = CancellationToken.None 828await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 852CancellationToken = CancellationToken.None 925CancellationToken = CancellationToken.None 1030CancellationToken = CancellationToken.None 1097CancellationToken.None); 1121CancellationToken = CancellationToken.None

86await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 125await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 155await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 194await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 350await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 399await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 421await ExecuteBeforeStartHooksAsync(app, CancellationToken.None);

165var entries = await containerAnnotation.Callback(new() { Model = keycloakResource, Services = app.Services }, CancellationToken.None); 190var entries = await containerAnnotation.Callback(new() { Model = keycloakResource, Services = app.Services }, CancellationToken.None);

37await HelmVersionValidator.EnsureMinimumVersionAsync(runner, CancellationToken.None); 44await HelmVersionValidator.EnsureMinimumVersionAsync(runner, CancellationToken.None); 56() => HelmVersionValidator.EnsureMinimumVersionAsync(runner, CancellationToken.None)); 70() => HelmVersionValidator.EnsureMinimumVersionAsync(runner, CancellationToken.None)); 86() => HelmVersionValidator.EnsureMinimumVersionAsync(runner, CancellationToken.None)); 99await HelmVersionValidator.EnsureMinimumVersionAsync(runner, CancellationToken.None);

822CancellationToken.None); 967outputPath, environment, CancellationToken.None); 996outputPath, environment, CancellationToken.None); 1026outputPath, environment, CancellationToken.None); 1102outputPath, environment, CancellationToken.None); 1271outputPath, environment, CancellationToken.None); 1295outputPath, environment, CancellationToken.None); 1468outputPath, environment, CancellationToken.None); 1527workspace.Path, env, CancellationToken.None); 1588workspace.Path, env, CancellationToken.None); 1633workspace.Path, env, CancellationToken.None); 1673workspace.Path, env, CancellationToken.None);

213() => ExecuteBeforeStartHooksAsync(app, CancellationToken.None));

518CancellationToken.None);

129() => ExecuteBeforeStartHooksAsync(app, CancellationToken.None)); 152() => ExecuteBeforeStartHooksAsync(app, CancellationToken.None)); 171await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 199await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 219await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 247await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 310await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 329await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 365() => ExecuteBeforeStartHooksAsync(app, CancellationToken.None)); 389await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 421() => ExecuteBeforeStartHooksAsync(app, CancellationToken.None)); 445await ExecuteBeforeStartHooksAsync(app, CancellationToken.None); 474() => ExecuteBeforeStartHooksAsync(app, CancellationToken.None)); 495await ExecuteBeforeStartHooksAsync(app, CancellationToken.None);

61CancellationToken.None);

109if (!await semaphore.WaitAsync(TimeSpan.Zero, CancellationToken.None).ConfigureAwait(false))

59CancellationToken.None)); 79CancellationToken.None).DefaultTimeout(); 92CancellationToken.None)); 99CancellationToken.None)); 120CancellationToken.None)); 141CancellationToken.None)); 175CancellationToken.None)); 192CancellationToken.None)); 196CancellationToken.None)); 223CancellationToken.None).DefaultTimeout()); 237CancellationToken.None)); 260CancellationToken.None); 274CancellationToken.None); 287CancellationToken.None); 295CancellationToken.None); 353CancellationToken.None)); 360CancellationToken.None); 377CancellationToken.None).DefaultTimeout(); 387CancellationToken.None).DefaultTimeout(); 413await subscriber.SubscribeAsync(eventing, execContext, CancellationToken.None).DefaultTimeout(); 418CancellationToken.None).DefaultTimeout(); 449await subscriber.SubscribeAsync(eventing, execContext, CancellationToken.None).DefaultTimeout(); 456CancellationToken.None).DefaultTimeout()); 477CancellationToken.None).DefaultTimeout()); 524CancellationToken.None)); 532CancellationToken.None)); 563CancellationToken.None)); 598CancellationToken.None).DefaultTimeout(); 620CancellationToken.None)); 663CancellationToken.None); 733CancellationToken.None); 786CancellationToken.None); 822CancellationToken.None); 851CancellationToken.None).DefaultTimeout(); 862CancellationToken.None); 869CancellationToken.None)); 908CancellationToken.None); 939CancellationToken.None).DefaultTimeout(); 950CancellationToken.None); 959CancellationToken.None)); 1046CancellationToken.None)); 1056CancellationToken.None)); 1060CancellationToken.None)); 1103CancellationToken.None)).DefaultTimeout(); 1154CancellationToken = CancellationToken.None, 1428await subscriber.SubscribeAsync(eventing, execContext, CancellationToken.None).DefaultTimeout();

36.PublishAsync(new BeforeResourceStartedEvent(device.Resource, app.Services), CancellationToken.None) 62.PublishAsync(new BeforeResourceStartedEvent(simulator.Resource, app.Services), CancellationToken.None) 87.PublishAsync(new BeforeResourceStartedEvent(device.Resource, app.Services), CancellationToken.None) 108.PublishAsync(new BeforeResourceStartedEvent(simulator.Resource, app.Services), CancellationToken.None) 127.PublishAsync(new BeforeResourceStartedEvent(device.Resource, app.Services), CancellationToken.None) 146.PublishAsync(new BeforeResourceStartedEvent(simulator.Resource, app.Services), CancellationToken.None)

297.PublishAsync(new BeforeResourceStartedEvent(platform.Resource, app.Services), CancellationToken.None) 594await environmentSubscriber.SubscribeAsync(eventing, executionContext, CancellationToken.None).DefaultTimeout(); 595await eventing.PublishAsync(new BeforeResourceStartedEvent(resource, app.Services), CancellationToken.None).DefaultTimeout(); 616await callback.Callback(new CommandLineArgsCallbackContext(args, resource, CancellationToken.None)).DefaultTimeout(); 776await appBuilder.Eventing.PublishAsync(new ResourceEndpointsAllocatedEvent(dashboard.Resource, app.Services), CancellationToken.None).DefaultTimeout(); 834CancellationToken.None).DefaultTimeout(); 846CancellationToken.None).DefaultTimeout(); 894CancellationToken.None).DefaultTimeout(); 944CancellationToken.None).DefaultTimeout(); 996await appBuilder.Eventing.PublishAsync(new BeforeStartEvent(app.Services, app.Services.GetRequiredService<DistributedApplicationModel>()), CancellationToken.None).DefaultTimeout(); 1000await appBuilder.Eventing.PublishAsync(new ResourceEndpointsAllocatedEvent(dashboard.Resource, app.Services), CancellationToken.None).DefaultTimeout(); 1120appBuilder.Eventing.PublishAsync(new BeforeResourceStartedEvent(tunnelConfig.DevTunnel.Resource, app.Services), CancellationToken.None).DefaultTimeout()); 1146appBuilder.Eventing.PublishAsync(new BeforeResourceStartedEvent(tunnelConfig.DevTunnel.Resource, app.Services), CancellationToken.None).DefaultTimeout()); 1177CancellationToken.None).DefaultTimeout()); 1228CancellationToken.None).DefaultTimeout()); 1252CancellationToken.None).DefaultTimeout(); 1344CancellationToken.None);

421var connectionString = await mongo1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 443var connectionString = await mongo1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None);

89var connectionString = await replicaSetResource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 110var connectionString = await replicaSetResource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 448Assert.Equal("admin", await properties.Single(p => p.Key == "Username").Value.GetValueAsync(CancellationToken.None)); 449Assert.Equal("admin", await properties.Single(p => p.Key == "AuthenticationDatabase").Value.GetValueAsync(CancellationToken.None)); 450Assert.Equal("SCRAM-SHA-256", await properties.Single(p => p.Key == "AuthenticationMechanism").Value.GetValueAsync(CancellationToken.None)); 451Assert.Equal("rs0", await properties.Single(p => p.Key == "ReplicaSetName").Value.GetValueAsync(CancellationToken.None)); 453var uri = await properties.Single(p => p.Key == "Uri").Value.GetValueAsync(CancellationToken.None); 454Assert.Equal(await rs.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None), uri);

524var entries = await createServers.Callback(new() { Model = pgadmin, Services = app.Services }, CancellationToken.None); 588var entries = await createBookmarks.Callback(new() { Model = pgweb, Services = app.Services }, CancellationToken.None);

64var resolvedUri = await mcpAnnotation.EndpointUrlResolver(mcpContainer, CancellationToken.None);

2593await eventing.PublishAsync(new BeforeStartEvent(app.Services, appModel), CancellationToken.None);

230await ((IValueProvider)httpReference).GetValueAsync(CancellationToken.None)); 232await ((IValueProvider)httpReference).GetValueAsync(new ValueProviderContext(), CancellationToken.None));

133return builder.BuildAsync(executionContext, CancellationToken.None).GetAwaiter().GetResult();

418process.WaitForExitAsync(CancellationToken.None), 427CancellationToken.None,

4880expression.GetValueAsync(CancellationToken.None).AsTask().GetAwaiter().GetResult() ?? string.Empty;

228CancellationToken.None)); 249CancellationToken.None); 269CancellationToken.None); 297NullLogger.Instance, kubeContext: null, ThrowingRunner, CancellationToken.None); 320CancellationToken.None);

109return await entry.ResolveArgumentsAsync(CancellationToken.None);

60CancellationToken.None); 99CancellationToken.None);

189ctExpr ?? Expression.Constant(CancellationToken.None, typeof(CancellationToken)), 204ctExpr ?? Expression.Constant(CancellationToken.None, typeof(CancellationToken)), 219ctExpr ?? Expression.Constant(CancellationToken.None, typeof(CancellationToken)), 234ctExpr ?? Expression.Constant(CancellationToken.None, typeof(CancellationToken)), 296if (cancellationToken != CancellationToken.None) 330ctExpr ?? Expression.Constant(CancellationToken.None, typeof(CancellationToken)), 349ctExpr ?? Expression.Constant(CancellationToken.None, typeof(CancellationToken)),

515if (cancellationToken == CancellationToken.None) 568return CancellationToken.None; 629return CancellationToken.None;

433Assert.Equal(CancellationToken.None, token);

147Assert.Throws<ObjectDisposedException>(() => registry.CreateLinked(CancellationToken.None));

30var export = service.ExportApi("TypeScript", "Aspire.Hosting", "13.5.0", CancellationToken.None); 31var repeatedExport = service.ExportApi("TypeScript", "Aspire.Hosting", "13.5.0", CancellationToken.None); 60var export = service.ExportApi("TypeScript", "Aspire.Hosting", "13.5.0", CancellationToken.None); 140() => service.ExportApi("TypeScript", "Contoso.Aspire.MetaPackage", "9.9.9", CancellationToken.None)); 143var export = service.ExportApi("TypeScript", "contoso.aspire.metapackage", "1.2.3", CancellationToken.None); 162var ex = Assert.Throws<LocalRpcException>(() => service.ExportApi("klingon", "Aspire.Hosting", "13.5.0", CancellationToken.None)); 177var ex = Assert.Throws<LocalRpcException>(() => service.ExportApi("Go", "Aspire.Hosting", "13.5.0", CancellationToken.None)); 192var ex = Assert.Throws<LocalRpcException>(() => service.ExportApi("TypeScript", packageName!, "13.5.0", CancellationToken.None)); 204var ex = Assert.Throws<LocalRpcException>(() => service.ExportApi("TypeScript", "Aspire.Hosting", packageVersion!, CancellationToken.None)); 213Assert.ThrowsAny<Exception>(() => service.ExportApi("TypeScript", "Aspire.Hosting", "13.5.0", CancellationToken.None));

139await server.StartAsync(CancellationToken.None); 199var stream = await ConnectToServerAsync(_socketPath, CancellationToken.None); 298=> _rpc.InvokeWithCancellationAsync<T>(methodName, arguments, CancellationToken.None);

24await detector.StartAsync(CancellationToken.None).WaitAsync(s_timeout); 47await detector.StartAsync(CancellationToken.None).WaitAsync(s_timeout); 72await detector.StartAsync(CancellationToken.None).WaitAsync(s_timeout); 97await detector.StartAsync(CancellationToken.None).WaitAsync(s_timeout); 122await detector.StartAsync(CancellationToken.None).WaitAsync(s_timeout); 152await detector.StartAsync(CancellationToken.None).WaitAsync(s_timeout);

98var stdoutTask = process.StandardOutput.ReadToEndAsync(CancellationToken.None); 99var stderrTask = process.StandardError.ReadToEndAsync(CancellationToken.None);

319CancellationToken.None,

538public DistributedApplication Build() => BuildAsync(CancellationToken.None).Result;

79CancellationToken = CancellationToken.None 85await annotation.MaterializeDockerfileAsync(context, CancellationToken.None); 113CancellationToken = CancellationToken.None 119await annotation.MaterializeDockerfileAsync(context, CancellationToken.None); 153CancellationToken = CancellationToken.None 159await annotation.MaterializeDockerfileAsync(context, CancellationToken.None); 160await annotation.MaterializeDockerfileAsync(context, CancellationToken.None); 194CancellationToken = CancellationToken.None 201.Select(_ => annotation.MaterializeDockerfileAsync(context, CancellationToken.None)); 301CancellationToken = CancellationToken.None

56var context = new DockerfileBuilderCallbackContext(new ContainerResource("test"), builder, services, CancellationToken.None); 83var context = new DockerfileBuilderCallbackContext(new ContainerResource("test"), builder, services, CancellationToken.None); 110var context = new DockerfileBuilderCallbackContext(new ContainerResource("test"), builder, services, CancellationToken.None); 140var context = new DockerfileBuilderCallbackContext(new ContainerResource("test"), builder, services, CancellationToken.None); 186var context = new DockerfileBuilderCallbackContext(new ContainerResource("test"), builder, services, CancellationToken.None); 221var context = new DockerfileBuilderCallbackContext(new ContainerResource("test"), builder, services, CancellationToken.None);

23var context = new DockerfileBuilderCallbackContext(resource, builder, services, CancellationToken.None); 39Assert.Throws<ArgumentNullException>(() => new DockerfileBuilderCallbackContext(null!, builder, services, CancellationToken.None)); 50Assert.Throws<ArgumentNullException>(() => new DockerfileBuilderCallbackContext(resource, null!, services, CancellationToken.None)); 61Assert.Throws<ArgumentNullException>(() => new DockerfileBuilderCallbackContext(resource, builder, null!, CancellationToken.None)); 71var context = new DockerfileBuilderCallbackContext(resource, builder, services, CancellationToken.None); 94var context = new DockerfileBuilderCallbackContext(resource, builder, services, CancellationToken.None); 115var context = new DockerfileBuilderCallbackContext(resource, builder, services, CancellationToken.None); 131var context = new DockerfileBuilderCallbackContext(resource, builder, services, CancellationToken.None);

99CancellationToken = CancellationToken.None 150CancellationToken = CancellationToken.None 186CancellationToken = CancellationToken.None 220CancellationToken = CancellationToken.None 261CancellationToken = CancellationToken.None 341CancellationToken = CancellationToken.None 377CancellationToken = CancellationToken.None 442CancellationToken = CancellationToken.None

24var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None); 35var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None); 64var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None); 78var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None); 93var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None); 108var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None); 124var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None); 140var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None); 155var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None); 187var result = await annotation.EndpointUrlResolver(resource, CancellationToken.None);

79await foreach (var _ in target.GetAppHostLogEntriesAsync(CancellationToken.None)) 151await foreach (var _ in target.GetPublishingActivitiesAsync(CancellationToken.None)) 222await foreach (var _ in target.GetResourceStatesAsync(CancellationToken.None))

110CancellationToken.None);

30await detector.StartAsync(CancellationToken.None).DefaultTimeout(); 50await detector.StartAsync(CancellationToken.None).DefaultTimeout(); 74await detector.StartAsync(CancellationToken.None).DefaultTimeout(); 105await detector.StartAsync(CancellationToken.None).DefaultTimeout(); 127await detector.StartAsync(CancellationToken.None).DefaultTimeout(); 159await detector.StartAsync(CancellationToken.None).DefaultTimeout(); 203await detector.StartAsync(CancellationToken.None).DefaultTimeout(); 235await detector.StartAsync(CancellationToken.None).DefaultTimeout();

50await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None).DefaultTimeout(); 100await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None).DefaultTimeout(); 193await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None).DefaultTimeout(); 246await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None).DefaultTimeout(); 262.BuildAsync(context, new FakeLogger(), CancellationToken.None) 449await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None).DefaultTimeout(); 463await eventing.PublishAsync(readyEvent, CancellationToken.None).DefaultTimeout(); 532await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None).DefaultTimeout(); 544await eventing.PublishAsync(readyEvent, CancellationToken.None).DefaultTimeout(); 604await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None); 688await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None); 757await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None); 824await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None); 869await hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None); 898() => hook.OnBeforeStartAsync(new BeforeStartEvent(new TestServiceProvider(), model), CancellationToken.None));

670var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => data.SendInteractionRequestAsync(response, CancellationToken.None)); 1218await dashboardServiceData.SendInteractionRequestAsync(request, CancellationToken.None); 1258await dashboardServiceData.SendInteractionRequestAsync(request, CancellationToken.None); 1314dashboardServiceData.SendInteractionRequestAsync(request, CancellationToken.None)); 1323CancellationToken.None); 1673var attachment = terminalService.AttachAsync(terminal.Id, gated, _ => Task.CompletedTask, CancellationToken.None); 1827var exception = await Record.ExceptionAsync(() => service.CloseTerminalAsync(terminal, CancellationToken.None)).DefaultTimeout();

22await stream.WriteEndedAsync(CancellationToken.None);

176ResourcePublisher publisher = new(CancellationToken.None);

715await appExecutor.StopResourceAsync(reference, CancellationToken.None); 717await appExecutor.StartResourceAsync(reference, CancellationToken.None); 1493await appExecutor.StopResourceAsync(reference, CancellationToken.None); 1494await appExecutor.StartResourceAsync(reference, CancellationToken.None); 1531await appExecutor.StopResourceAsync(reference, CancellationToken.None); 1532await appExecutor.StartResourceAsync(reference, CancellationToken.None); 4630var ex = await Assert.ThrowsAsync<DistributedApplicationException>(async () => await appExecutor.StartResourceAsync(resourceReference, CancellationToken.None)); 6006await appExecutor.StartResourceAsync(reference, CancellationToken.None); 6041() => appExecutor.StartResourceAsync(reference, CancellationToken.None)); 9133() => appExecutor.StartResourceAsync(reference, CancellationToken.None)); 9204await appExecutor.StartResourceAsync(reference, CancellationToken.None); 9213await appExecutor.StartResourceAsync(reference, CancellationToken.None); 9266() => appExecutor.StartResourceAsync(reference, CancellationToken.None)); 9275await appExecutor.StartResourceAsync(reference, CancellationToken.None); 9691await appExecutor.StartResourceAsync(reference, CancellationToken.None); 9736await appExecutor.StartResourceAsync(reference, CancellationToken.None); 9793await appExecutor.StartResourceAsync(reference, CancellationToken.None); 9846await appExecutor.StartResourceAsync(reference, CancellationToken.None); 10297await appExecutor.StartResourceAsync(reference, CancellationToken.None).DefaultTimeout(); 10350var startTask = appExecutor.StartResourceAsync(reference, CancellationToken.None); 10353await appExecutor.StopAsync(CancellationToken.None).DefaultTimeout();

109await dcpHost.EnsureDcpContainerRuntimeAsync(CancellationToken.None).DefaultTimeout(); 153await dcpHost.EnsureDevelopmentCertificateTrustAsync(CancellationToken.None).DefaultTimeout(); 206await dcpHost.EnsureDcpContainerRuntimeAsync(CancellationToken.None).DefaultTimeout(); 265await dcpHost.EnsureDcpContainerRuntimeAsync(CancellationToken.None).DefaultTimeout(); 324await dcpHost.EnsureDcpContainerRuntimeAsync(CancellationToken.None).DefaultTimeout(); 378await dcpHost.EnsureDcpContainerRuntimeAsync(CancellationToken.None).DefaultTimeout(); 450await dcpHost.EnsureDcpContainerRuntimeAsync(CancellationToken.None).DefaultTimeout(); 503await dcpHost.PrepareDcpTlsCertificateAsync(CancellationToken.None); 547await dcpHost.PrepareDcpTlsCertificateAsync(CancellationToken.None); 880await dcpHost.EnsureDevelopmentCertificateTrustAsync(CancellationToken.None).DefaultTimeout(); 930await dcpHost.EnsureDevelopmentCertificateTrustAsync(CancellationToken.None).DefaultTimeout(); 990await dcpHost.EnsureDevelopmentCertificateTrustAsync(CancellationToken.None).DefaultTimeout(); 1041await dcpHost.EnsureDevelopmentCertificateTrustAsync(CancellationToken.None).DefaultTimeout(); 1099await dcpHost.EnsureDevelopmentCertificateTrustAsync(CancellationToken.None).DefaultTimeout(); 1164await dcpHost.EnsureDevelopmentCertificateTrustAsync(CancellationToken.None).DefaultTimeout();

277CancellationToken.None);

254() => executable.Resource.CreateLaunchConfigurationAsync(null!, CancellationToken.None));

177await lifecycle.StartingAsync(CancellationToken.None); 181await lifecycle.StopAsync(CancellationToken.None); 1458await ((IHostedService)dashboardServiceHost).StartAsync(CancellationToken.None); 1467await ((IHostedService)dashboardServiceHost).StopAsync(CancellationToken.None); 1488await ((IHostedService)dashboardServiceHost).StartAsync(CancellationToken.None); 1502await ((IHostedService)dashboardServiceHost).StopAsync(CancellationToken.None);

21var getValueTask = endpointRef.GetValueAsync(CancellationToken.None); 40var getValueTask = endpointExpr.GetValueAsync(CancellationToken.None); 60var url = await endpointExpr.GetValueAsync(CancellationToken.None); 74var getValueTask = hostExpr.GetValueAsync(CancellationToken.None); 93var getValueTask = portExpr.GetValueAsync(CancellationToken.None); 112var scheme = await schemeExpr.GetValueAsync(CancellationToken.None); 126var ipv4 = await ipv4Expr.GetValueAsync(CancellationToken.None); 140var targetPort = await targetPortExpr.GetValueAsync(CancellationToken.None); 154var getValueTask = targetPortExpr.GetValueAsync(CancellationToken.None); 193var task1 = expr1.GetValueAsync(CancellationToken.None); 194var task2 = expr2.GetValueAsync(CancellationToken.None); 195var task3 = expr3.GetValueAsync(CancellationToken.None); 392var consumer = new WithWaitStartedNotification<string?>(waitStarted, endpointRef.GetValueAsync(CancellationToken.None).GetAwaiter());

332await eventing.PublishAsync(testEvent, CancellationToken.None); 431await eventing.PublishAsync(testEvent, CancellationToken.None); 454await eventing.PublishAsync(testEvent, CancellationToken.None);

532var resolvedPath = await capturedBundlePath.GetValueAsync(CancellationToken.None); 632var pkcs12Bytes = await factory(metadata.Certificates, CancellationToken.None); 840_ = await metadata.KeyPathReference.GetValueAsync(CancellationToken.None); 843_ = await metadata.CertificateWithKeyPathReference.GetValueAsync(CancellationToken.None); 846_ = await metadata.PfxPathReference.GetValueAsync(CancellationToken.None);

29var resolvedValue = await ExpressionResolver.ResolveAsync(testData.ValueProvider, context, CancellationToken.None); 35async Task<ResolvedValue> ResolveAsync() => await ExpressionResolver.ResolveAsync(testData.ValueProvider, context, CancellationToken.None); 133var connectionString = await ExpressionResolver.ResolveAsync(csRef, context, CancellationToken.None).DefaultTimeout();

471CancellationToken.None).DefaultTimeout();

118CancellationToken.None).DefaultTimeout(); 154CancellationToken.None).DefaultTimeout(); 168var message = HttpHealthCheckHelpers.GetFriendlyErrorMessage(uri, exception, CancellationToken.None); 181var message = HttpHealthCheckHelpers.GetFriendlyErrorMessage(uri, exception, CancellationToken.None); 192var message = HttpHealthCheckHelpers.GetFriendlyErrorMessage(uri, exception, CancellationToken.None); 216var message = HttpHealthCheckHelpers.GetFriendlyErrorMessage(uri, exception, CancellationToken.None);

129await foreach (var interaction in subscription.WithCancellation(CancellationToken.None)) 902await foreach (var interaction in subscription.WithCancellation(CancellationToken.None)) 955await foreach (var interaction in subscription.WithCancellation(CancellationToken.None)) 1332CancellationToken.None);

52await service.StopAsync(CancellationToken.None).DefaultTimeout(); 86await service.StopAsync(CancellationToken.None).DefaultTimeout(); 123await service.StopAsync(CancellationToken.None).DefaultTimeout(); 162await service.StopAsync(CancellationToken.None).DefaultTimeout(); 215await service.StopAsync(CancellationToken.None).DefaultTimeout(); 250await foreach (var evt in notifications.WatchAsync(CancellationToken.None)) 261await foreach (var evt in notifications.WatchAsync(CancellationToken.None)) 277await foreach (var batch in loggers.WatchAsync(host).WithCancellation(cts?.Token ?? CancellationToken.None))

70CancellationToken.None, KnownResourceTypes.Executable, resource.Resource, resource.Resource.Name, 115await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 163await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 204await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 272await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 333await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 381await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 451await events.PublishAsync(new OnConnectionStringAvailableContext(CancellationToken.None, parentResource.Resource)); 488await events.PublishAsync(new OnConnectionStringAvailableContext(CancellationToken.None, resource.Resource)); 489await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Executable, resource.Resource, "test-resource-dcp")); 516await applicationEventing.PublishAsync(new ConnectionStringAvailableEvent(resource.Resource, app.Services), CancellationToken.None); 517await applicationEventing.PublishAsync(new ConnectionStringAvailableEvent(resource.Resource, app.Services), CancellationToken.None); 560CancellationToken.None, 589CancellationToken.None, 616await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Tool, resource.Resource, "tool-dcp")); 645await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 681await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 687CancellationToken.None, KnownResourceTypes.Executable, waiter.Resource, waiter.Resource.Name)); 727await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 736CancellationToken.None, KnownResourceTypes.Executable, waiter.Resource, "waiter-abc123")); 787await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 794CancellationToken.None, KnownResourceTypes.Executable, waiter.Resource, "waiter-abc123")); 840await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 845CancellationToken.None, KnownResourceTypes.Executable, waiter.Resource, "waiter-abc123")); 893await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 899CancellationToken.None, KnownResourceTypes.Executable, waiter.Resource, "waiter-abc123")); 907CancellationToken.None, KnownResourceTypes.Executable, waiter.Resource, "waiter-def456")); 955await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1023await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1059await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1094await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1353await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1357CancellationToken.None, 1401await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1405CancellationToken.None, 1477await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1534await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1584await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None));

201var handleTask = parameterProcessor.HandleUnresolvedParametersAsync(parameters, CancellationToken.None); 310await parameterProcessor.SetParameterCoreAsync(parameterWithMissingValue, CreateSetParameterArguments("resolvedValue"), CancellationToken.None).DefaultTimeout(); 394var handleTask = parameterProcessor.HandleUnresolvedParametersAsync([parameter], CancellationToken.None); 444_ = parameterProcessor.HandleUnresolvedParametersAsync(parameters, CancellationToken.None); 487_ = parameterProcessor.HandleUnresolvedParametersAsync(parameters, CancellationToken.None); 522_ = parameterProcessor.HandleUnresolvedParametersAsync(parameters, CancellationToken.None); 561_ = parameterProcessor.HandleUnresolvedParametersAsync(parameters, CancellationToken.None); 936CancellationToken = CancellationToken.None 962CancellationToken = CancellationToken.None 996CancellationToken = CancellationToken.None 1004CancellationToken = CancellationToken.None 1033CancellationToken = CancellationToken.None 1065CancellationToken = CancellationToken.None 1098var result = await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("newValue"), CancellationToken.None).DefaultTimeout(); 1102Assert.Equal("newValue", await parameter.GetValueAsync(CancellationToken.None).DefaultTimeout()); 1115var result = await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments(value: null), CancellationToken.None).DefaultTimeout(); 1134var result = await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("resolvedValue"), CancellationToken.None).DefaultTimeout(); 1137Assert.Equal("resolvedValue", await parameter.GetValueAsync(CancellationToken.None).DefaultTimeout()); 1150await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("firstValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1151Assert.Equal("firstValue", await parameter.GetValueAsync(CancellationToken.None).DefaultTimeout()); 1155await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("secondValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1157Assert.Equal("secondValue", await parameter.GetValueAsync(CancellationToken.None).DefaultTimeout()); 1174var setParameterTask = parameterProcessor.SetParameterAsync(parameter, CancellationToken.None); 1184Assert.Equal("newValue", await parameter.GetValueAsync(CancellationToken.None).DefaultTimeout()); 1225var result = await parameterProcessor.SetParameterCoreAsync(secretParam, CreateSetParameterArguments("replacement-secret"), CancellationToken.None).DefaultTimeout(); 1413var handleTask = parameterProcessor.HandleUnresolvedParametersAsync(parameters, CancellationToken.None); 1454var handleTask = parameterProcessor.HandleUnresolvedParametersAsync(parameters, CancellationToken.None); 1498var handleTask = parameterProcessor.HandleUnresolvedParametersAsync(parameters, CancellationToken.None); 1526await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1529var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(deleteFromUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1545await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1547var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, new InteractionInputCollection([]), CancellationToken.None).DefaultTimeout(); 1562await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1564var result = await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(deleteFromUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1583await parameterProcessor.SetParameterCoreAsync(parameter, CreateSetParameterArguments("savedValue", saveToUserSecrets: "true"), CancellationToken.None).DefaultTimeout(); 1584await parameterProcessor.DeleteParameterCoreAsync(parameter, CreateDeleteParameterArguments(), CancellationToken.None).DefaultTimeout(); 1598Assert.Equal("newValue", await parameter.GetValueAsync(CancellationToken.None).DefaultTimeout()); 1613var setParameterTask = parameterProcessor.SetParameterAsync(parameter, CancellationToken.None); 1623var deleteParameterTask = parameterProcessor.DeleteParameterAsync(parameter, CancellationToken.None); 1646Assert.Equal("newValue", await parameter.GetValueAsync(CancellationToken.None).DefaultTimeout());

36await BuiltInDistributedApplicationEventSubscriptionHandlers.WarnPersistentContainersWithoutUserSecrets(beforeStartEvent, CancellationToken.None); 60await BuiltInDistributedApplicationEventSubscriptionHandlers.WarnPersistentContainersWithoutUserSecrets(beforeStartEvent, CancellationToken.None); 82await BuiltInDistributedApplicationEventSubscriptionHandlers.WarnPersistentContainersWithoutUserSecrets(beforeStartEvent, CancellationToken.None);

988CancellationToken.None);

87var runtime = await resolver.ResolveAsync(CancellationToken.None);

48cancellationToken: CancellationToken.None); 422cancellationToken: CancellationToken.None); 444cancellationToken: CancellationToken.None);

31var step = await reporter.CreateStepAsync(title, CancellationToken.None); 61var step = await reporter.CreateStepAsync("Child Step", "parent-step-id", 2, CancellationToken.None); 73await step.CompleteAsync("Done", CompletionState.Completed, CancellationToken.None); 85var parentStep = Assert.IsType<ReportingStep>(await reporter.CreateStepAsync("Parent Step", CancellationToken.None)); 91var childStep = Assert.IsType<ReportingStep>(await reporter.CreateStepAsync("Child Step", "Parent Step", 1, CancellationToken.None)); 110var step = await reporter.CreateStepAsync("Parent Step", CancellationToken.None); 117var task = await step.CreateTaskAsync(statusText, CancellationToken.None); 150() => nonExistentStep.CreateTaskAsync("Test Task", CancellationToken.None)); 162var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 163await step.CompleteAsync("Completed", CompletionState.Completed, CancellationToken.None); 167() => step.CreateTaskAsync("Test Task", CancellationToken.None)); 181var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 187await step.CompleteAsync(completionText, isError ? CompletionState.CompletedWithError : CompletionState.Completed, CancellationToken.None); 212var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 213var task = await step.CreateTaskAsync("Initial status", CancellationToken.None); 220await task.UpdateAsync(newStatusText, CancellationToken.None); 243var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 244var task = await step.CreateTaskAsync("Initial status", CancellationToken.None); 247var dummyStep = await reporter.CreateStepAsync("Dummy Step", CancellationToken.None); 254() => invalidTask.UpdateAsync("New status", CancellationToken.None)); 265var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 266var task = await step.CreateTaskAsync("Initial status", CancellationToken.None); 267await step.CompleteAsync("Completed", CompletionState.Completed, CancellationToken.None); 271() => task.UpdateAsync("New status", CancellationToken.None)); 284var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 285var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 292await task.CompleteAsync(completionMessage, cancellationToken: CancellationToken.None); 319var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 320var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 321await step.CompleteAsync("Completed", CompletionState.Completed, CancellationToken.None); 325() => task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None)); 341await reporter.CompletePublishAsync(new PublishCompletionOptions { CompletionState = completionState }, CancellationToken.None); 362await reporter.CompletePublishAsync(new PublishCompletionOptions { CompletionMessage = expectedStatusText, CompletionState = CompletionState.CompletedWithError }, CancellationToken.None); 381var step1 = await reporter.CreateStepAsync("Step 1", CancellationToken.None); 382var step2 = await reporter.CreateStepAsync("Step 2", CancellationToken.None); 383var step3 = await reporter.CreateStepAsync("Step 3", CancellationToken.None); 385var task1 = await step1.CreateTaskAsync("Task 1", CancellationToken.None); 386await task1.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 387await step1.CompleteAsync("Step 1 completed", CompletionState.Completed, CancellationToken.None); 389var task2 = await step2.CreateTaskAsync("Task 2", CancellationToken.None); 390await task2.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 391await step2.CompleteAsync("Step 2 completed with warning", CompletionState.CompletedWithWarning, CancellationToken.None); 393var task3 = await step3.CreateTaskAsync("Task 3", CancellationToken.None); 394await task3.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 395await step3.CompleteAsync("Step 3 failed", CompletionState.CompletedWithError, CancellationToken.None); 402await reporter.CompletePublishAsync(options: null, cancellationToken: CancellationToken.None); 418var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 419var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 422await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 435var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 436var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 439await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 445await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 460var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 461var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 464await task.CompleteAsync((string?)null, CompletionState.Completed, cancellationToken: CancellationToken.None); 470await task.CompleteAsync("Error", CompletionState.CompletedWithError, cancellationToken: CancellationToken.None); 485var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 488await step.CompleteAsync("Complete", cancellationToken: CancellationToken.None); 494await step.CompleteAsync("Complete again", cancellationToken: CancellationToken.None); 510var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 513await step.CompleteAsync("Complete", CompletionState.Completed, cancellationToken: CancellationToken.None); 519await step.CompleteAsync("Error", CompletionState.CompletedWithError, cancellationToken: CancellationToken.None); 535var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 536var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 539await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); 542await step.CompleteAsync("Step completed", CompletionState.Completed, CancellationToken.None); 547() => task.UpdateAsync("New status", CancellationToken.None)); 552await task.CompleteAsync((string?)null, cancellationToken: CancellationToken.None); // Should not throw 553await task.CompleteAsync("Error", CompletionState.CompletedWithError, cancellationToken: CancellationToken.None); // Should also not throw (noop) 557() => step.CreateTaskAsync("New Task", CancellationToken.None)); 566await using var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 582await reporter.CompleteInteractionAsync(promptId, responses, updateResponse: false, cancellationToken: CancellationToken.None).DefaultTimeout(); 610await reporter.CompleteInteractionAsync(promptId, responses, updateResponse: false, CancellationToken.None).DefaultTimeout(); 639await reporter.CompleteInteractionAsync(promptId, responses, updateResponse: false, CancellationToken.None).DefaultTimeout(); 671await reporter.CompleteInteractionAsync(activity.Data.Id, responses, cancellationToken: CancellationToken.None).DefaultTimeout(); 704reporter.CompleteInteractionAsync(activity.Data.Id, responses: null, cancellationToken: CancellationToken.None)); 743await reporter.CompleteInteractionAsync(notificationId, responses, updateResponse: false, CancellationToken.None).DefaultTimeout(); 756var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 771var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 799var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 800var task1 = await step.CreateTaskAsync("Task 1", CancellationToken.None); 801var task2 = await step.CreateTaskAsync("Task 2", CancellationToken.None); 804await task1.SucceedAsync((string?)null, CancellationToken.None); 805await task2.SucceedAsync((string?)null, CancellationToken.None); 833var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 836await step.CompleteAsync("Step completed manually", CompletionState.Completed, CancellationToken.None); 858var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 859var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 867await taskInternal.WarnAsync(completionMessage, CancellationToken.None); 893var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 894var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 902await taskInternal.FailAsync(completionMessage, CancellationToken.None); 931await reporter.CompletePublishAsync(new PublishCompletionOptions { CompletionState = completionState }, CancellationToken.None); 952await reporter.CompletePublishAsync(new PublishCompletionOptions { CompletionMessage = expectedStatusText, CompletionState = CompletionState.CompletedWithError }, CancellationToken.None); 978await reporter.CompletePublishAsync(new PublishCompletionOptions { CompletionState = CompletionState.Completed, PipelineSummary = pipelineSummary }, CancellationToken.None); 1005await reporter.CompletePublishAsync(new PublishCompletionOptions { CompletionState = CompletionState.Completed }, CancellationToken.None); 1023var step = await reporter.CreateStepAsync(markdownTitle, CancellationToken.None); 1044var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1048var task = await step.CreateTaskAsync(markdownStatusText, CancellationToken.None); 1070var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1101var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1102await step.CompleteAsync("Completed", CompletionState.Completed, CancellationToken.None); 1121var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1122var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 1129await task.CompleteAsync(markdownCompletionMessage, cancellationToken: CancellationToken.None); 1147var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1151var task = await step.CreateTaskAsync(new MarkdownString("**Bold** task"), CancellationToken.None); 1167var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1168var task = await step.CreateTaskAsync("Initial status", CancellationToken.None); 1172await task.UpdateAsync(new MarkdownString("**Updated** status"), CancellationToken.None); 1187var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1188var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 1192await task.CompleteAsync(new MarkdownString("Deployed to **Azure**"), CompletionState.Completed, CancellationToken.None); 1207var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1211await step.CompleteAsync(new MarkdownString("Step **completed** successfully"), CompletionState.Completed, CancellationToken.None); 1227var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1228var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 1231await task.CompleteAsync("Warning message", CompletionState.CompletedWithWarning, CancellationToken.None); 1237await task.CompleteAsync("Different warning message", CompletionState.CompletedWithWarning, CancellationToken.None); 1252var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1253var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 1256await task.CompleteAsync("Error message", CompletionState.CompletedWithError, CancellationToken.None); 1262await task.CompleteAsync("Different error message", CompletionState.CompletedWithError, CancellationToken.None); 1277var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1280await step.CompleteAsync("Warning", CompletionState.CompletedWithWarning, CancellationToken.None); 1286await step.CompleteAsync("Different warning", CompletionState.CompletedWithWarning, CancellationToken.None); 1301var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1304await step.CompleteAsync("Error", CompletionState.CompletedWithError, CancellationToken.None); 1310await step.CompleteAsync("Different error", CompletionState.CompletedWithError, CancellationToken.None); 1331var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1332var task = await step.CreateTaskAsync("Test Task", CancellationToken.None); 1335await task.CompleteAsync("First completion", firstState, CancellationToken.None); 1341await task.CompleteAsync("Second completion", secondState, CancellationToken.None); 1362var step = await reporter.CreateStepAsync("Test Step", CancellationToken.None); 1365await step.CompleteAsync("First completion", firstState, CancellationToken.None); 1371await step.CompleteAsync("Second completion", secondState, CancellationToken.None);