24 references to Subscribe
Aspire.Hosting (1)
ResourceLoggerForwarderService.cs (1)
70using var subscription = resourceLoggerService.Subscribe(resourceId, logEvent =>
Aspire.Hosting.Tests (23)
Dcp\DcpExecutorTests.cs (14)
1713using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 1782using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 1866using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 1959using var subscription = resourceLoggerService.Subscribe(blockingDcpResourceName, _ => { }); 2037using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2117using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2201using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2323IDisposable? firstSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2354secondSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2479IDisposable? firstSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2510secondSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2805using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 2986using var subscription = resourceLoggerService.Subscribe(dcpResourceName, _ => { }); 3071using var subscription = resourceLoggerService.Subscribe(dcpResourceName, _ => { });
ResourceLoggerServiceTests.cs (9)
319using var subscription = service.Subscribe(resourceName, logLines.AddRange); 354using var subscription = service.Subscribe(resourceName, logLines.AddRange); 400subscription = service.Subscribe(resourceName, batch => 461using var subscription = service.Subscribe(resourceName, _ => { }); 477using (service.Subscribe(testResource.Name, _ => { })) 511using var subscription = service.Subscribe(resourceName, batch => 554using var subscription = service.Subscribe(resourceName, batch => 602using var stableSubscription = service.Subscribe(resourceName, batch => 623using var subscription = service.Subscribe(resourceName, batch =>