26 references to Subscribe
Aspire.Hosting (1)
ResourceLoggerForwarderService.cs (1)
70using var subscription = resourceLoggerService.Subscribe(resourceId, logEvent =>
Aspire.Hosting.Tests (25)
Dcp\DcpExecutorTests.cs (14)
2647using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 2716using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2800using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 2893using var subscription = resourceLoggerService.Subscribe(blockingDcpResourceName, _ => { }); 2971using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 3051using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 3135using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 3257IDisposable? firstSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 3288secondSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 3413IDisposable? firstSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 3444secondSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 3852using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 4033using var subscription = resourceLoggerService.Subscribe(dcpResourceName, _ => { }); 4118using 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 =>
WaitForTests.cs (2)
818using var subscription = resourceLoggerService.Subscribe(containerResource.Resource.Name, lines => 868using var subscription = resourceLoggerService.Subscribe(containerResource.Resource.Name, lines =>