32 references to PublishAsync
Aspire.Hosting (18)
Dcp\DcpExecutor.cs (18)
176await _executorEvents.PublishAsync(new OnResourcesPreparedContext(ct)).ConfigureAwait(false); 273await _executorEvents.PublishAsync(new OnEndpointsAllocatedContext(ct)).ConfigureAwait(false); 528await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.Metadata.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false); 803await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceKind, appModelResource, resourceName, status, s => 1636await _executorEvents.PublishAsync(new OnResourceChangedContext( 1645await _executorEvents.PublishAsync(new OnResourceChangedContext( 1661await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resource, DcpResourceName: null)).ConfigureAwait(false); 1678await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1686await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1697await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, resource, DcpResourceName: null)).ConfigureAwait(false); 2083await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 2088await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 2098await _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); 2134await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.Metadata.Name)).ConfigureAwait(false); 2656await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false); 2662await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false); 2675await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false); 2680await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false);
Aspire.Hosting.Tests (14)
Orchestrator\ApplicationOrchestratorTests.cs (14)
68await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 116await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 157await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 225await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 286await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 334await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 404await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, parentResource.Resource, parentResource.Resource.Name)); 619await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 622await events.PublishAsync(new OnResourceChangedContext( 666await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 669await events.PublishAsync(new OnResourceChangedContext( 741await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 798await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 848await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None));