52 references to PublishAsync
Aspire.Hosting (16)
Dcp\DcpExecutor.cs (14)
183await _executorEvents.PublishAsync(new OnResourcesPreparedContext(ct)).ConfigureAwait(false); 981await _executorEvents.PublishAsync(new OnResourceChangedContext( 999await _executorEvents.PublishAsync(new OnResourceChangedContext( 1020await _executorEvents.PublishAsync(new OnResourceChangedContext( 1045await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, modelResource, startingDcpName)).ConfigureAwait(false); 1056await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, modelResource, DcpResourceName: null)).ConfigureAwait(false); 1093await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1098await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1258await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1264await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, er.ModelResource, er.DcpResourceName)).ConfigureAwait(false); 1275await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1287await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1307await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName, ex.Message)).ConfigureAwait(false); 1444await _executorEvents.PublishAsync(new OnConnectionStringAvailableContext(ct, resource)).ConfigureAwait(false);
Dcp\DcpResourceWatcher.cs (2)
401publishTask = _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownToken, resourceType, appModelResource, resource.Metadata.Name, status, 1020publishTask = _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownToken, resourceKind, appModelResource, resourceName, status, status.State, s =>
Aspire.Hosting.Tests (36)
Orchestrator\ApplicationOrchestratorTests.cs (36)
66Task PublishStateAsync(string? state, string? previousState) => events.PublishAsync(new OnResourceChangedContext( 112await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 160await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 201await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 269await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 330await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 378await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 448await events.PublishAsync(new OnConnectionStringAvailableContext(CancellationToken.None, parentResource.Resource)); 485await events.PublishAsync(new OnConnectionStringAvailableContext(CancellationToken.None, resource.Resource)); 486await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Executable, resource.Resource, "test-resource-dcp")); 556await events.PublishAsync(new OnResourceFailedToStartContext( 585await events.PublishAsync(new OnResourceFailedToStartContext( 613await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Tool, resource.Resource, "tool-dcp")); 642await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 678await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 683var startingTask = events.PublishAsync(new OnResourceStartingContext( 724await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 732var startingTask = events.PublishAsync(new OnResourceStartingContext( 784await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 790var startingTask = events.PublishAsync(new OnResourceStartingContext( 837await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 841var startingTask = events.PublishAsync(new OnResourceStartingContext( 890await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 895var startingFirstReplicaTask = events.PublishAsync(new OnResourceStartingContext( 903var startingSecondReplicaTask = events.PublishAsync(new OnResourceStartingContext( 952await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1020await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1056await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1091await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1350await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1353await events.PublishAsync(new OnResourceChangedContext( 1398await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1401await events.PublishAsync(new OnResourceChangedContext( 1474await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1531await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1581await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None));