32 references to PublishAsync
Aspire.Hosting (18)
Dcp\DcpExecutor.cs (18)
166await _executorEvents.PublishAsync(new OnResourcesPreparedContext(cancellationToken)).ConfigureAwait(false); 187await _executorEvents.PublishAsync(new OnEndpointsAllocatedContext(cancellationToken)).ConfigureAwait(false); 464await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.Metadata.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false); 734await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceKind, appModelResource, resourceName, status, s => 1525await _executorEvents.PublishAsync(new OnResourceChangedContext( 1534await _executorEvents.PublishAsync(new OnResourceChangedContext( 1550await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resource, DcpResourceName: null)).ConfigureAwait(false); 1567await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1575await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1586await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, resource, DcpResourceName: null)).ConfigureAwait(false); 1935await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1940await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1950await _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); 1986await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.Metadata.Name)).ConfigureAwait(false); 2474await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false); 2480await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false); 2493await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false); 2498await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, appResource.ModelResource, appResource.DcpResourceName)).ConfigureAwait(false);
Aspire.Hosting.Tests (14)
Orchestrator\ApplicationOrchestratorTests.cs (14)
67await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 115await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 156await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 224await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 285await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 333await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 403await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, parentResource.Resource, parentResource.Resource.Name)); 618await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 621await events.PublishAsync(new OnResourceChangedContext( 665await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 668await events.PublishAsync(new OnResourceChangedContext( 740await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 797await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 847await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None));