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)
2161using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 2230using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2314using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 2407using var subscription = resourceLoggerService.Subscribe(blockingDcpResourceName, _ => { }); 2485using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2565using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2649using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2771IDisposable? firstSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2802secondSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2927IDisposable? firstSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 2958secondSubscription = resourceLoggerService.Subscribe(dcpResourceName, AddLogLines); 3366using var subscription = resourceLoggerService.Subscribe(dcpResourceName, batch => 3547using var subscription = resourceLoggerService.Subscribe(dcpResourceName, _ => { }); 3632using 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 =>