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)
2162using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 2231using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2315using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 2408using var subscription = resourceLoggerService.Subscribe(blockingDcpResourceName, _ => { }); 2486using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2566using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2650using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2772IDisposable? firstSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2803secondSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2928IDisposable? firstSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2959secondSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 3367using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 3548using var subscription = resourceLoggerService.Subscribe(dcpResourceName, _ => { }); 3633using 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 =>