51 references to PublishAsync
Aspire.Hosting (16)
Dcp\DcpExecutor.cs (14)
191await _executorEvents.PublishAsync(new OnResourcesPreparedContext(ct)).ConfigureAwait(false); 945await _executorEvents.PublishAsync(new OnResourceChangedContext( 962await _executorEvents.PublishAsync(new OnResourceChangedContext( 982await _executorEvents.PublishAsync(new OnResourceChangedContext( 1006await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, modelResource, startingDcpName)).ConfigureAwait(false); 1017await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, modelResource, DcpResourceName: null)).ConfigureAwait(false); 1054await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1059await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1219await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1225await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, er.ModelResource, er.DcpResourceName)).ConfigureAwait(false); 1236await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1248await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1267await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName, ex.Message)).ConfigureAwait(false); 1398await _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); 908await _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));