51 references to PublishAsync
Aspire.Hosting (16)
Dcp\DcpExecutor.cs (14)
192await _executorEvents.PublishAsync(new OnResourcesPreparedContext(ct)).ConfigureAwait(false); 998await _executorEvents.PublishAsync(new OnResourceChangedContext( 1015await _executorEvents.PublishAsync(new OnResourceChangedContext( 1035await _executorEvents.PublishAsync(new OnResourceChangedContext( 1059await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, modelResource, startingDcpName)).ConfigureAwait(false); 1070await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, modelResource, DcpResourceName: null)).ConfigureAwait(false); 1107await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1112await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1272await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1278await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, er.ModelResource, er.DcpResourceName)).ConfigureAwait(false); 1289await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1301await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1320await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName, ex.Message)).ConfigureAwait(false); 1451await _executorEvents.PublishAsync(new OnConnectionStringAvailableContext(ct, resource)).ConfigureAwait(false);
Dcp\DcpResourceWatcher.cs (2)
352await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownToken, resourceType, appModelResource, resource.Metadata.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false); 956await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownToken, resourceKind, appModelResource, resourceName, status, s =>
Aspire.Hosting.Tests (35)
Orchestrator\ApplicationOrchestratorTests.cs (35)
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 OnConnectionStringAvailableContext(CancellationToken.None, parentResource.Resource)); 440await events.PublishAsync(new OnConnectionStringAvailableContext(CancellationToken.None, resource.Resource)); 441await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Executable, resource.Resource, "test-resource-dcp")); 511await events.PublishAsync(new OnResourceFailedToStartContext( 540await events.PublishAsync(new OnResourceFailedToStartContext( 568await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Tool, resource.Resource, "tool-dcp")); 597await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 633await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 638var startingTask = events.PublishAsync(new OnResourceStartingContext( 679await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 687var startingTask = events.PublishAsync(new OnResourceStartingContext( 739await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 745var startingTask = events.PublishAsync(new OnResourceStartingContext( 792await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 796var startingTask = events.PublishAsync(new OnResourceStartingContext( 845await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 850var startingFirstReplicaTask = events.PublishAsync(new OnResourceStartingContext( 858var startingSecondReplicaTask = events.PublishAsync(new OnResourceStartingContext( 907await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 975await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1011await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1046await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1305await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1308await events.PublishAsync(new OnResourceChangedContext( 1352await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1355await events.PublishAsync(new OnResourceChangedContext( 1427await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1484await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1534await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None));