25 references to PublishAsync
Aspire.Hosting (18)
Dcp\DcpExecutor.cs (18)
146
await _executorEvents.
PublishAsync
(new OnResourcesPreparedContext(cancellationToken)).ConfigureAwait(false);
401
await _executorEvents.
PublishAsync
(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.Metadata.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false);
671
await _executorEvents.
PublishAsync
(new OnResourceChangedContext(_shutdownCancellation.Token, resourceKind, appModelResource, resourceName, status, s =>
802
await _executorEvents.
PublishAsync
(new OnEndpointsAllocatedContext(cancellationToken)).ConfigureAwait(false);
1105
await _executorEvents.
PublishAsync
(new OnResourceChangedContext(
1112
await _executorEvents.
PublishAsync
(new OnResourceStartingContext(cancellationToken, resourceType, resource, DcpResourceName: null)).ConfigureAwait(false);
1118
await _executorEvents.
PublishAsync
(new OnResourceChangedContext(cancellationToken, resourceType, resource, er.DcpResource.Metadata.Name, new ResourceStatus(KnownResourceStates.NotStarted, null, null), s => s with { State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, null) })).ConfigureAwait(false);
1131
await _executorEvents.
PublishAsync
(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false);
1139
await _executorEvents.
PublishAsync
(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false);
1150
await _executorEvents.
PublishAsync
(new OnResourceFailedToStartContext(cancellationToken, resourceType, resource, DcpResourceName: null)).ConfigureAwait(false);
1386
await _executorEvents.
PublishAsync
(new OnResourceFailedToStartContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false);
1391
await _executorEvents.
PublishAsync
(new OnResourceFailedToStartContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false);
1427
await _executorEvents.
PublishAsync
(new OnResourceChangedContext(_shutdownCancellation.Token, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName, new ResourceStatus(null, null, null), s => _snapshotBuilder.ToSnapshot((Container)cr.DcpResource, s))).ConfigureAwait(false);
1451
await _executorEvents.
PublishAsync
(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.Metadata.Name)).ConfigureAwait(false);
1797
await _executorEvents.
PublishAsync
(new OnResourceStartingContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false);
1803
await _executorEvents.
PublishAsync
(new OnResourceStartingContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false);
1816
await _executorEvents.
PublishAsync
(new OnResourceFailedToStartContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false);
1821
await _executorEvents.
PublishAsync
(new OnResourceFailedToStartContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false);
Aspire.Hosting.Tests (7)
Orchestrator\ApplicationOrchestratorTests.cs (7)
57
await events.
PublishAsync
(new OnResourcesPreparedContext(CancellationToken.None));
104
await events.
PublishAsync
(new OnResourcesPreparedContext(CancellationToken.None));
144
await events.
PublishAsync
(new OnResourcesPreparedContext(CancellationToken.None));
211
await events.
PublishAsync
(new OnResourcesPreparedContext(CancellationToken.None));
271
await events.
PublishAsync
(new OnResourcesPreparedContext(CancellationToken.None));
318
await events.
PublishAsync
(new OnResourcesPreparedContext(CancellationToken.None));
387
await events.
PublishAsync
(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, parentResource.Resource, parentResource.Resource.Name));