405 references to PublishUpdateAsync
Aspire.Hosting (25)
ApplicationModel\CommandsConfigurationExtensions.cs (5)
235await resourceNotificationService.PublishUpdateAsync(projectResource, s => 281await resourceNotificationService.PublishUpdateAsync(projectResource, s => s with 295await resourceNotificationService.PublishUpdateAsync(projectResource, s => s with 361await resourceNotificationService.PublishUpdateAsync(projectResource, s => s with 373await resourceNotificationService.PublishUpdateAsync(projectResource, s => s with
ApplicationModel\CustomResourceSnapshotExtensions.cs (1)
21/// This method is intended for use with <see cref="ResourceNotificationService.PublishUpdateAsync(IResource, Func{CustomResourceSnapshot, CustomResourceSnapshot})"/>
ApplicationModel\ResourceNotificationService.cs (2)
639return PublishUpdateAsync(resource, s => 657return PublishUpdateAsync(resource, s => s with
Ats\NotificationExports.cs (1)
99return notificationService.PublishUpdateAsync(resource.Resource, snapshot =>
ConnectionStringBuilderExtensions.cs (2)
97await evt.Notifications.PublishUpdateAsync(r, s => s with 111await evt.Notifications.PublishUpdateAsync(r, s => s with
DotnetToolResourceExtensions.cs (1)
109await rns.PublishUpdateAsync(resource, x => x with
ExternalServiceBuilderExtensions.cs (3)
145await e.Notifications.PublishUpdateAsync(resource, snapshot => snapshot with 157await e.Notifications.PublishUpdateAsync(resource, snapshot => snapshot with 170await e.Notifications.PublishUpdateAsync(resource, snapshot => snapshot with
Health\ResourceHealthCheckService.cs (2)
197await resourceNotificationService.PublishUpdateAsync(resource, s => 278await resourceNotificationService.PublishUpdateAsync(resource, s => s with
Lifecycle\TerminalHostFailureDiagnosticService.cs (1)
109await notifications.PublishUpdateAsync(host, s => s with { IsHidden = false })
Orchestrator\ApplicationOrchestrator.cs (6)
104await _notificationService.PublishUpdateAsync(resourceWithConnectionString, state => state with 215await _notificationService.PublishUpdateAsync(resource, s => s with { Urls = [.. urls] }).ConfigureAwait(false); 287: notificationService.PublishUpdateAsync(resource, stateFactory); 620await _notificationService.PublishUpdateAsync(context.Resource, s => s with { State = stateSnapshot }).ConfigureAwait(false); 689await _notificationService.PublishUpdateAsync(child, s => s with 717await _notificationService.PublishUpdateAsync(resource, s =>
Orchestrator\ParameterProcessor.cs (1)
931await notificationService.PublishUpdateAsync(parameterResource, s =>
Aspire.Hosting.Azure (13)
AzureProvisioningController.cs (3)
3637await notificationService.PublishUpdateAsync(resource, state => ApplyActiveOperationProperties(resource, state)).ConfigureAwait(false); 3677await notificationService.PublishUpdateAsync(targetResource, state => ApplyActiveOperationProperties(targetResource, stateFactory(state))).ConfigureAwait(false); 4173await notificationService.PublishUpdateAsync(azureEnvironmentResource, existingState => ApplyActiveOperationProperties(azureEnvironmentResource, existingState with
Provisioning\Provisioners\BicepProvisioner.cs (10)
127await notificationService.PublishUpdateAsync(resource, state => 329await notificationService.PublishUpdateAsync(resource, state => state with 443await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 529await notificationService.PublishUpdateAsync(resource, state => state with 551await notificationService.PublishUpdateAsync(resource, state => 580await notificationService.PublishUpdateAsync(resource, state => 653await notificationService.PublishUpdateAsync(resource, state => state with 684await notificationService.PublishUpdateAsync(resource, state => 815await notificationService.PublishUpdateAsync(resource, state => 983await notificationService.PublishUpdateAsync(resource, state =>
Aspire.Hosting.Azure.EntraId (2)
EntraIdResourceExtensions.cs (2)
170await evt.Notifications.PublishUpdateAsync(resource, snapshot => snapshot with 222return evt.Notifications.PublishUpdateAsync(resource, snapshot => snapshot with
Aspire.Hosting.Azure.EntraId.Tests (1)
EntraIdInitializationTests.cs (1)
259await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with
Aspire.Hosting.Azure.Functions (1)
DurableTask\DurableTaskResourceExtensions.cs (1)
240await notifications.PublishUpdateAsync(r, snapshot => snapshot with
Aspire.Hosting.Azure.Kusto (1)
AzureKustoBuilderExtensions.cs (1)
314await rns.PublishUpdateAsync(databaseResource, state => state with
Aspire.Hosting.Azure.Tests (60)
AzureBicepProvisionerTests.cs (1)
1259await notifications.PublishUpdateAsync(resource, state => state with
AzureEnvironmentResourceExtensionsTests.cs (59)
327await notifications.PublishUpdateAsync(environmentResource, state => state with 336await notifications.PublishUpdateAsync(storage.Resource, state => state with 703await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 738await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 1361await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Waiting for Deployment", KnownResourceStateStyles.Info) }); 1416await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Creating ARM Deployment", KnownResourceStateStyles.Info) }); 1493await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new(AzureProvisioningController.WaitingForDeploymentState, KnownResourceStateStyles.Info) }); 1663await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1701await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1784await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 1785await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 1879await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 1948await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 1949await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1950await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2027await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2095await notifications.PublishUpdateAsync(storage.Resource, state => state with 2102await notifications.PublishUpdateAsync(storage2.Resource, state => state with 2170await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2171await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2223await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2224await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2225await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2284await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2285await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2701await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2702await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2703await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2775await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = new("Failed to Provision", KnownResourceStateStyles.Error) }); 2776await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2829await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2889await notifications.PublishUpdateAsync(visibleResource, state => state with { State = KnownResourceStates.Running }); 2944await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3017await notifications.PublishUpdateAsync(storage.Resource, state => state with 3077await notifications.PublishUpdateAsync(storage.Resource, state => state with 3150await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3203await notifications.PublishUpdateAsync(storage.Resource, state => state with 3266await notifications.PublishUpdateAsync(storage.Resource, state => state with 3338await notifications.PublishUpdateAsync(storage.Resource, state => state with 3395await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3396await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3610await notifications.PublishUpdateAsync(storage.Resource, state => state with 3753await notifications.PublishUpdateAsync(storage2, state => state with 3840await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3912await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Canceled", KnownResourceStateStyles.Info) }); 3992await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = new("Canceled", KnownResourceStateStyles.Info) }); 4066await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 4118await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4164await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 4210await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4324await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4325await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4377await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4378await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4435await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4436await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4437await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 4479await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4480await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running });
Aspire.Hosting.Blazor (4)
BlazorGatewayExtensions.cs (1)
530await notificationService.PublishUpdateAsync(reg.AppBuilder.Resource, snapshot => snapshot with
BrowserDebuggerHelper.cs (3)
197await notificationService.PublishUpdateAsync(commandTarget.Resource, s => s).ConfigureAwait(false); 256await notificationService.PublishUpdateAsync(commandTarget.Resource, s => s).ConfigureAwait(false); 324await resourceNotificationService.PublishUpdateAsync(commandTargetResource, s => s).ConfigureAwait(false);
Aspire.Hosting.Blazor.Tests (5)
BrowserDebuggerHelperTests.cs (5)
27await notificationService.PublishUpdateAsync( 40await notificationService.PublishUpdateAsync( 59await notificationService.PublishUpdateAsync( 73await notificationService.PublishUpdateAsync( 96await notificationService.PublishUpdateAsync(
Aspire.Hosting.Browsers (2)
BrowserLogsBuilderExtensions.cs (1)
292notifications.PublishUpdateAsync(browserLogsResource, snapshot => snapshot);
BrowserLogsConfigurationManager.cs (1)
421return resourceNotificationService.PublishUpdateAsync(resource, snapshot => snapshot with
Aspire.Hosting.Browsers.Tests (3)
BrowserLogsBuilderExtensionsTests.cs (1)
1352await app.ResourceNotifications.PublishUpdateAsync(web.Resource, snapshot => snapshot with
src\Aspire.Hosting.Browsers\BrowserLogsBuilderExtensions.cs (1)
292notifications.PublishUpdateAsync(browserLogsResource, snapshot => snapshot);
src\Aspire.Hosting.Browsers\BrowserLogsConfigurationManager.cs (1)
421return resourceNotificationService.PublishUpdateAsync(resource, snapshot => snapshot with
Aspire.Hosting.DevTunnels (7)
DevTunnelMonitor.cs (2)
615await _notifications.PublishUpdateAsync(_resource, snapshot => WithConnectionHealth(snapshot, _resource.Name, healthy, description)).ConfigureAwait(false); 683return _notifications.PublishUpdateAsync(port, snapshot => snapshot with
DevTunnelResourceBuilderExtensions.cs (5)
199await notifications.PublishUpdateAsync(portResource, snapshot => snapshot with 726await notifications.PublishUpdateAsync(portResource, snapshot => 743await notifications.PublishUpdateAsync(portResource, snapshot => 811await notifications.PublishUpdateAsync(portResource, snapshot => snapshot with 832await notifications.PublishUpdateAsync(portResource, snapshot => stoppedSnapshot = snapshot with
Aspire.Hosting.DevTunnels.Tests (7)
DevTunnelMonitorTests.cs (6)
183await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 207await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 257async (_, _) => await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 316await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 348await test.App.ResourceNotifications.PublishUpdateAsync(test.Port, s => s with 479await test.App.ResourceNotifications.PublishUpdateAsync(test.Tunnel, s => s with { State = KnownResourceStates.FailedToStart });
TestDevTunnelMonitor.cs (1)
60await App.ResourceNotifications.PublishUpdateAsync(Tunnel, s => s with { State = KnownResourceStates.Running });
Aspire.Hosting.Dotnet.Tests (24)
DotnetProjectBuildCoordinatorTests.cs (24)
225await app.ResourceNotifications.PublishUpdateAsync( 242await app.ResourceNotifications.PublishUpdateAsync( 441await app.ResourceNotifications.PublishUpdateAsync( 1434await app.ResourceNotifications.PublishUpdateAsync( 1688await app.ResourceNotifications.PublishUpdateAsync( 1788await app.ResourceNotifications.PublishUpdateAsync( 1803await app.ResourceNotifications.PublishUpdateAsync( 1918await app.ResourceNotifications.PublishUpdateAsync( 2042await app.ResourceNotifications.PublishUpdateAsync( 2079await app.ResourceNotifications.PublishUpdateAsync( 3200await app.ResourceNotifications.PublishUpdateAsync(builds[0], snapshot => snapshot with 3205await app.ResourceNotifications.PublishUpdateAsync(builds[1], snapshot => snapshot with 3298await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 3306await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 3313await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 3320await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 3356await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 3378await app.ResourceNotifications.PublishUpdateAsync(build, snapshot => snapshot with 3383await app.ResourceNotifications.PublishUpdateAsync(rebuilder, snapshot => snapshot with 3391await app.ResourceNotifications.PublishUpdateAsync(rebuilder, snapshot => snapshot with 3398await app.ResourceNotifications.PublishUpdateAsync(rebuilder, snapshot => snapshot with 3440await app.ResourceNotifications.PublishUpdateAsync(finalBuild, snapshot => snapshot with 3473await app.ResourceNotifications.PublishUpdateAsync( 3494await app.ResourceNotifications.PublishUpdateAsync(
Aspire.Hosting.EntityFrameworkCore (8)
EFResourceBuilderExtensions.cs (8)
521await notificationService.PublishUpdateAsync(toolResource, s => s with 557await notificationService.PublishUpdateAsync(toolResource, s => s with 569await notificationService.PublishUpdateAsync(toolResource, s => s with 581await notificationService.PublishUpdateAsync(toolResource, s => s with 599await notificationService.PublishUpdateAsync(toolResource, s => s with 636await notificationService.PublishUpdateAsync(toolResource, s => s with 661await notificationService.PublishUpdateAsync(toolResource, s => s with 985resourceNotificationService.PublishUpdateAsync(migrationResource, s => s with
Aspire.Hosting.EntityFrameworkCore.Tests (1)
TestServices\TestEfTool.cs (1)
34await context.Services.GetRequiredService<ResourceNotificationService>().PublishUpdateAsync(
Aspire.Hosting.Foundry (20)
FoundryExtensions.cs (9)
349await rns.PublishUpdateAsync(resource, state => state with 369await rns.PublishUpdateAsync(resource, state => state with 377await rns.PublishUpdateAsync(resource, state => state with 409await rns.PublishUpdateAsync(deployment, state => state with 428await rns.PublishUpdateAsync(deployment, state => state with 447await rns.PublishUpdateAsync(deployment, state => state with 457await rns.PublishUpdateAsync(deployment, state => state with 465await rns.PublishUpdateAsync(deployment, state => state with 476await rns.PublishUpdateAsync(deployment, state => state with
PromptAgent\AzurePromptAgentResource.cs (6)
331await notificationService.PublishUpdateAsync(tool, s => s with 337await notificationService.PublishUpdateAsync(this, s => s with 344await notificationService.PublishUpdateAsync(this, s => s with 358await notificationService.PublishUpdateAsync(tool, s => s with 367await notificationService.PublishUpdateAsync(this, s => s with 380await notificationService.PublishUpdateAsync(this, s => s with
Toolbox\FoundryToolboxResource.cs (5)
333await notificationService.PublishUpdateAsync(this, snapshot => snapshot with 343await notificationService.PublishUpdateAsync(this, snapshot => snapshot with 355await notificationService.PublishUpdateAsync(this, snapshot => snapshot with 380await notificationService.PublishUpdateAsync(this, snapshot => snapshot with 404await notificationService.PublishUpdateAsync(this, snapshot => snapshot with
Aspire.Hosting.Foundry.Tests (1)
ToolboxTests.cs (1)
927await notifications.PublishUpdateAsync(mcp.Resource, snapshot => snapshot with
Aspire.Hosting.Maui (6)
Lifecycle\MauiBuildQueueEventSubscriber.cs (3)
113await notificationService.PublishUpdateAsync(resource, s => s with 125await notificationService.PublishUpdateAsync(resource, s => s with 578await notificationService.PublishUpdateAsync(resource, s =>
Lifecycle\UnsupportedPlatformEventSubscriber.cs (1)
34await notificationService.PublishUpdateAsync(resource, s => s with
Utilities\MauiAndroidEnvironmentAnnotation.cs (1)
107await notificationService.PublishUpdateAsync(resource, s => s with
Utilities\MauiiOSEnvironmentAnnotation.cs (1)
107await notificationService.PublishUpdateAsync(resource, s => s with
Aspire.Hosting.Maui.Tests (12)
MauiBuildQueueTests.cs (7)
580await env.NotificationService.PublishUpdateAsync(env.Android, s => s with 647await env.NotificationService.PublishUpdateAsync(env.Android, s => s with 668await env.NotificationService.PublishUpdateAsync(env.Android, s => s with 717await env.NotificationService.PublishUpdateAsync(env.Android, s => s with 735await env.NotificationService.PublishUpdateAsync(env.Android, s => s with 743await env.NotificationService.PublishUpdateAsync(env.Android, s => s with 915await env.NotificationService.PublishUpdateAsync(env.Android, s => s with
MauiPlatformExtensionsTests.cs (5)
922.PublishUpdateAsync(dashboard.Resource, snapshot => snapshot with 1219.PublishUpdateAsync(dashboard.Resource, snapshot => snapshot with 1239.PublishUpdateAsync(dashboard.Resource, snapshot => snapshot with 1330await notificationService.PublishUpdateAsync(dashboard.Resource, snapshot => snapshot with 1346await notificationService.PublishUpdateAsync(dashboard.Resource, snapshot => snapshot with
Aspire.Hosting.MongoDB (7)
ReplicaSet\MongoDBReplicaSetBuilderExtensions.cs (7)
116await evt.Notifications.PublishUpdateAsync(resource, s => s with 134await evt.Notifications.PublishUpdateAsync(resource, s => s with 359await evt.Notifications.PublishUpdateAsync(resource, s => s with 367await evt.Notifications.PublishUpdateAsync(resource, s => s with 491.PublishUpdateAsync(builder.Resource, s => 507.PublishUpdateAsync(builder.Resource, s => 529.PublishUpdateAsync(builder.Resource, s =>
Aspire.Hosting.MongoDB.Tests (2)
ReplicaSet\AddMongoDBReplicaSetTests.cs (1)
336await notifications.PublishUpdateAsync(replicaSet.Resource, snapshot => snapshot with
tests\Shared\ContainerReplCommandTestBase.cs (1)
76await notifications.PublishUpdateAsync(resource.Resource, snapshot => snapshot with
Aspire.Hosting.MySql.Tests (1)
tests\Shared\ContainerReplCommandTestBase.cs (1)
76await notifications.PublishUpdateAsync(resource.Resource, snapshot => snapshot with
Aspire.Hosting.OpenAI (2)
OpenAIExtensions.cs (2)
84await evt.Notifications.PublishUpdateAsync(r, s => s with 130await evt.Notifications.PublishUpdateAsync(r, s => s with
Aspire.Hosting.PostgreSQL.Tests (1)
tests\Shared\ContainerReplCommandTestBase.cs (1)
76await notifications.PublishUpdateAsync(resource.Resource, snapshot => snapshot with
Aspire.Hosting.Redis.Tests (1)
tests\Shared\ContainerReplCommandTestBase.cs (1)
76await notifications.PublishUpdateAsync(resource.Resource, snapshot => snapshot with
Aspire.Hosting.SqlServer.Tests (1)
tests\Shared\ContainerReplCommandTestBase.cs (1)
76await notifications.PublishUpdateAsync(resource.Resource, snapshot => snapshot with
Aspire.Hosting.Testing.Tests (4)
DashboardUrlTests.cs (2)
110await app.ResourceNotifications.PublishUpdateAsync( 138await app.ResourceNotifications.PublishUpdateAsync(
ResourceLoggerForwarderServiceTests.cs (2)
56await resourceNotificationService.PublishUpdateAsync(myresource, snapshot => snapshot with { State = "Running" }); 106await resourceNotificationService.PublishUpdateAsync(myresource, snapshot => snapshot with { State = "Running" });
Aspire.Hosting.Tests (168)
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (26)
181await notificationService.PublishUpdateAsync(custom.Resource, s => s with 346await notificationService.PublishUpdateAsync(custom.Resource, s => s with 403await notificationService.PublishUpdateAsync(owner.Resource, s => s with 452await notificationService.PublishUpdateAsync(owner.Resource, s => s with 514await notificationService.PublishUpdateAsync(owner.Resource, s => s with 543await notificationService.PublishUpdateAsync(owner.Resource, s => s with 590await notificationService.PublishUpdateAsync(owner.Resource, s => s with 617await notificationService.PublishUpdateAsync(owner.Resource, s => s with 660await notificationService.PublishUpdateAsync(owner.Resource, s => s with 688await notificationService.PublishUpdateAsync(owner.Resource, s => s with 731await notificationService.PublishUpdateAsync(owner.Resource, s => s with 756await notificationService.PublishUpdateAsync(owner.Resource, s => s with 820await notificationService.PublishUpdateAsync(mcpResource.Resource, s => s with 824await notificationService.PublishUpdateAsync(owner.Resource, s => s with 880await notificationService.PublishUpdateAsync(owner.Resource, s => s with 1033await notificationService.PublishUpdateAsync(owner.Resource, s => s with 1096await notificationService.PublishUpdateAsync(owner.Resource, s => s with 1112await notificationService.PublishUpdateAsync(owner.Resource, s => s with 1149await notificationService.PublishUpdateAsync(custom.Resource, s => s with 1221await notificationService.PublishUpdateAsync(custom.Resource, s => s with 1257await notificationService.PublishUpdateAsync(custom.Resource, s => s with 1297await notificationService.PublishUpdateAsync(custom.Resource, s => s with 1356await notificationService.PublishUpdateAsync(custom.Resource, s => s with 1392await notificationService.PublishUpdateAsync(custom.Resource, s => s with 1945await notificationService.PublishUpdateAsync(hidden.Resource, snapshot => snapshot with 2169await notificationService.PublishUpdateAsync(dashboard, snapshot => snapshot with
Codespaces\CodespacesUrlRewriterTests.cs (1)
73await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with
Dashboard\DashboardEventHandlersTests.cs (2)
64await resourceNotificationService.PublishUpdateAsync(dashboardResource, s => s).DefaultTimeout(); 135await resourceNotificationService.PublishUpdateAsync(dashboardResource, s => s).DefaultTimeout();
Dashboard\DashboardServiceDataTerminalTests.cs (3)
35await notifications.PublishUpdateAsync(resource, s => s with { State = new ResourceStateSnapshot("Running", null) }).DefaultTimeout(); 50await notifications.PublishUpdateAsync(resource, s => s with { State = new ResourceStateSnapshot("Running", null) }).DefaultTimeout(); 110await notifications.PublishUpdateAsync(resource, s => s with { State = new ResourceStateSnapshot("Running", null) }).DefaultTimeout();
Dashboard\DashboardServiceTests.cs (4)
210await resourceNotificationService.PublishUpdateAsync(testResource, s => 315await resourceNotificationService.PublishUpdateAsync(testResource, s => 374await resourceNotificationService.PublishUpdateAsync(testResource, s => 437await resourceNotificationService.PublishUpdateAsync(testResource, s =>
Health\ResourceHealthCheckServiceTests.cs (22)
33await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 41await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 73await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 81await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 116await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 124await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 163await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 178await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 186await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 229await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 270await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 313await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 349await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 380await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 442await app.ResourceNotifications.PublishUpdateAsync(parent.Resource, s => s with 487await app.ResourceNotifications.PublishUpdateAsync(parent.Resource, s => s with 538await app.ResourceNotifications.PublishUpdateAsync(parent.Resource, s => s with 546await app.ResourceNotifications.PublishUpdateAsync(child.Resource, s => s with 582await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 590await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 628await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with 636await app.ResourceNotifications.PublishUpdateAsync(resource.Resource, s => s with
Lifecycle\TerminalHostFailureDiagnosticServiceTests.cs (6)
32await notifications.PublishUpdateAsync(host, s => s with 71await notifications.PublishUpdateAsync(host, s => s with 102await notifications.PublishUpdateAsync(host, s => s with 143await notifications.PublishUpdateAsync(host, s => s with 181await notifications.PublishUpdateAsync(host, s => s with 196await notifications.PublishUpdateAsync(host, s => s with
Orchestrator\ApplicationOrchestratorTests.cs (3)
957await resourceNotificationService.PublishUpdateAsync(waiter.Resource, s => s with { State = KnownResourceStates.Starting }).DefaultTimeout(); 1017await resourceNotificationService.PublishUpdateAsync(waiter.Resource, s => s with { State = KnownResourceStates.Starting }); 1150await @event.Notifications.PublishUpdateAsync(resource, s => s with
ResourceNotificationTests.cs (78)
87await notificationService.PublishUpdateAsync(resource, state => state).DefaultTimeout(); 122await notificationService.PublishUpdateAsync(resource, state => state with { Properties = state.Properties.Add(new("A", "value")) }).DefaultTimeout(); 124await notificationService.PublishUpdateAsync(resource, state => state with { Properties = state.Properties.Add(new("B", "value")) }).DefaultTimeout(); 153await notificationService.PublishUpdateAsync(resource, snapshot => 200await notificationService.PublishUpdateAsync(resource1, state => state with { Properties = state.Properties.Add(new("A", "value")) }).DefaultTimeout(); 202await notificationService.PublishUpdateAsync(resource2, state => state with { Properties = state.Properties.Add(new("B", "value")) }).DefaultTimeout(); 241await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 257await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 272await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 287await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with { State = "SomeOtherState" }).DefaultTimeout(); 309await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = KnownResourceStates.Running }).DefaultTimeout(); 331await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeOtherState" }).DefaultTimeout(); 357await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeOtherState" }).DefaultTimeout(); 374await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 425await notificationService.PublishUpdateAsync(dependency1, s => s with 438await notificationService.PublishUpdateAsync(dependency2, s => s with 473await notificationService.PublishUpdateAsync(dependency1, s => 491await notificationService.PublishUpdateAsync(dependency2, s => 529await notificationService.PublishUpdateAsync(dependency1, s => s with 543await notificationService.PublishUpdateAsync(dependency2, s => s with 567await notificationService.PublishUpdateAsync(resource, s => s with 583await notificationService.PublishUpdateAsync(dependency, s => s with 610await notificationService.PublishUpdateAsync(resource, s => s with { State = state }).DefaultTimeout(); 615await notificationService.PublishUpdateAsync(dependency, s => s with 663await notificationService.PublishUpdateAsync(dependency, s => s with 693await notificationService.PublishUpdateAsync(dependency, s => s with 718await notificationService.PublishUpdateAsync(resource, s => s with 733await notificationService.PublishUpdateAsync(dependency, s => s with 772await notificationService.PublishUpdateAsync(dependency, s => s with 835await notificationService.PublishUpdateAsync(resource, s => s with 844await notificationService.PublishUpdateAsync(resource, s => s with 860await notificationService.PublishUpdateAsync(dependency, s => s with 865await notificationService.PublishUpdateAsync(resource, s => s with 893await notificationService.PublishUpdateAsync(dependency, s => s with 958await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 969await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 979await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "NewState" }).DefaultTimeout(); 989await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = null }).DefaultTimeout(); 999await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "" }).DefaultTimeout(); 1009await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = " " }).DefaultTimeout(); 1027await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { CreationTimeStamp = createdDate }).DefaultTimeout(); 1028await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 1029await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { ExitCode = 0 }).DefaultTimeout(); 1105await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1112await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1157await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1193await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1324await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1330await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1369await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1394await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1402await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1428await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1451await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1465await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1491await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1539await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1557await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1579await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1587await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1600await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1618await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1635await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1651await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1656await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1705await notificationService.PublishUpdateAsync(resourceBuilder.Resource, snapshot => snapshot with { State = state, ExitCode = exitCode }).DefaultTimeout(); 1749await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 1753await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 1758await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with { State = "SomeOtherState" }).DefaultTimeout(); 1814await notificationService.PublishUpdateAsync(resource, BuildSnapshot).DefaultTimeout(); 1818await notificationService.PublishUpdateAsync(resource, BuildSnapshot).DefaultTimeout(); 1823await notificationService.PublishUpdateAsync(resource, snapshot => BuildSnapshot(snapshot) with 1843await notificationService.PublishUpdateAsync(resource, static snapshot => snapshot).DefaultTimeout(); 1847await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1867await notificationService.PublishUpdateAsync(resource, static snapshot => snapshot).DefaultTimeout(); 1870await notificationService.PublishUpdateAsync(resource, snapshot => MutateProperty(snapshot, property)).DefaultTimeout(); 1886await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with 1899await notificationService.PublishUpdateAsync(resource, snapshot => snapshot with
WaitForTests.cs (15)
110await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 141await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 181await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 219await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 330await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 364await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 372await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 411await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 419await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 459await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 506await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 561await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 615await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 766await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with 878await app.ResourceNotifications.PublishUpdateAsync(dependency.Resource, s => s with
WithHttpCommandTests.cs (6)
627await app.ResourceNotifications.PublishUpdateAsync(serviceA.Resource, s => s with 950await app.ResourceNotifications.PublishUpdateAsync(service.Resource, s => s with 962await app.ResourceNotifications.PublishUpdateAsync(service.Resource, s => s with 1005await app.ResourceNotifications.PublishUpdateAsync(service.Resource, s => s with 1020await app.ResourceNotifications.PublishUpdateAsync(service.Resource, s => s with 1059await app.ResourceNotifications.PublishUpdateAsync(resource, s => s with
WithUrlsTests.cs (2)
590await e.Notifications.PublishUpdateAsync(custom, s => s with 597.PublishUpdateAsync(e.Resource, s => s with
Aspire.Hosting.Valkey.Tests (1)
tests\Shared\ContainerReplCommandTestBase.cs (1)
76await notifications.PublishUpdateAsync(resource.Resource, snapshot => snapshot with
CustomResources.AppHost (11)
TalkingClockResource.cs (9)
76await notification.PublishUpdateAsync(resource, s => s with 81await notification.PublishUpdateAsync(resource.TickHand, s => s with 86await notification.PublishUpdateAsync(resource.TockHand, s => s with 100await notification.PublishUpdateAsync(resource, 102await notification.PublishUpdateAsync(resource.TickHand, 104await notification.PublishUpdateAsync(resource.TockHand, 110await notification.PublishUpdateAsync(resource, 112await notification.PublishUpdateAsync(resource.TickHand, 114await notification.PublishUpdateAsync(resource.TockHand,
TestResource.cs (2)
54await notificationService.PublishUpdateAsync(resource, state => state with 65await notificationService.PublishUpdateAsync(resource, state => state with
HealthChecksSandbox.AppHost (1)
AppHost.cs (1)
135await notificationService.PublishUpdateAsync(
Stress.AppHost (2)
TestResource.cs (2)
168await notificationService.PublishUpdateAsync(resource, state => state with 179await notificationService.PublishUpdateAsync(resource, state => state with