1 write to _notificationService
Aspire.Hosting (1)
Orchestrator\ApplicationOrchestrator.cs (1)
59_notificationService = notificationService;
15 references to _notificationService
Aspire.Hosting (15)
Orchestrator\ApplicationOrchestrator.cs (15)
104await _notificationService.PublishUpdateAsync(resourceWithConnectionString, state => state with 153var waitForNonWaitingStateTask = _notificationService.WaitForResourceAsync( 174var waitForDependenciesTask = _notificationService.WaitForDependenciesAsync(@event.Resource, cts.Token); 215await _notificationService.PublishUpdateAsync(resource, s => s with { Urls = [.. urls] }).ConfigureAwait(false); 245await PublishUpdateAsync(_notificationService, context.Resource, context.DcpResourceName, s => s with 258await PublishUpdateAsync(_notificationService, context.Resource, context.DcpResourceName, s => s with 584if (_notificationService.TryGetCurrentState(context.DcpResourceName, out var previousResourceEvent)) 589await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, context.UpdateSnapshot).ConfigureAwait(false); 605if (_notificationService.TryGetCurrentState(context.DcpResourceName, out var currentResourceEvent)) 621await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with { State = stateSnapshot }).ConfigureAwait(false); 630await _notificationService.PublishUpdateAsync(context.Resource, s => s with { State = stateSnapshot }).ConfigureAwait(false); 661await _notificationService.PublishUpdateAsync( 699await _notificationService.PublishUpdateAsync(child, s => s with 727await _notificationService.PublishUpdateAsync(resource, s => 739var initializeEvent = new InitializeResourceEvent(resource, _eventing, _loggerService, _notificationService, _serviceProvider);