53 references to PublishAsync
Aspire.Hosting (17)
Dcp\DcpExecutor.cs (15)
183await _executorEvents.PublishAsync(new OnResourcesPreparedContext(ct)).ConfigureAwait(false); 258await _executorEvents.PublishAsync(new OnEndpointsAllocatedContext(ct, endpointEvents)).ConfigureAwait(false); 993await _executorEvents.PublishAsync(new OnResourceChangedContext( 1011await _executorEvents.PublishAsync(new OnResourceChangedContext( 1032await _executorEvents.PublishAsync(new OnResourceChangedContext( 1057await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, modelResource, startingDcpName)).ConfigureAwait(false); 1068await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, modelResource, DcpResourceName: null)).ConfigureAwait(false); 1105await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1110await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1273await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, cr.ModelResource, cr.DcpResourceName)).ConfigureAwait(false); 1279await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, er.ModelResource, er.DcpResourceName)).ConfigureAwait(false); 1290await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1302await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, resourceType, resourceReference.ModelResource, resourceReference.DcpResourceName)).ConfigureAwait(false); 1322await _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)
571Task PublishStateAsync(string? state, string? previousState) => events.PublishAsync(new OnResourceChangedContext( 617await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 665await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 706await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 774await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 835await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 883await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 953await events.PublishAsync(new OnConnectionStringAvailableContext(CancellationToken.None, parentResource.Resource)); 990await events.PublishAsync(new OnConnectionStringAvailableContext(CancellationToken.None, resource.Resource)); 991await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Executable, resource.Resource, "test-resource-dcp")); 1061await events.PublishAsync(new OnResourceFailedToStartContext( 1090await events.PublishAsync(new OnResourceFailedToStartContext( 1118await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Tool, resource.Resource, "tool-dcp")); 1147await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1183await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1188var startingTask = events.PublishAsync(new OnResourceStartingContext( 1229await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1237var startingTask = events.PublishAsync(new OnResourceStartingContext( 1289await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1295var startingTask = events.PublishAsync(new OnResourceStartingContext( 1342await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1346var startingTask = events.PublishAsync(new OnResourceStartingContext( 1395await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1400var startingFirstReplicaTask = events.PublishAsync(new OnResourceStartingContext( 1408var startingSecondReplicaTask = events.PublishAsync(new OnResourceStartingContext( 1457await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1525await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1561await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1596await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1856await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1859await events.PublishAsync(new OnResourceChangedContext( 1904await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 1907await events.PublishAsync(new OnResourceChangedContext( 1980await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 2037await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None)); 2087await events.PublishAsync(new OnResourcesPreparedContext(CancellationToken.None));