6 references to PumpAsync
Aspire.Hosting.DevTunnels (2)
DevTunnelCli.cs (2)
270stdoutTask = PumpAsync(process.StandardOutput, line => onOutput(false, line), cancellationToken); 271stderrTask = PumpAsync(process.StandardError, line => onOutput(true, line), cancellationToken);
Aspire.Hosting.DevTunnels.Tests (4)
DevTunnelCliOutputTests.cs (4)
18var pump = DevTunnelCli.PumpAsync(reader, lines.Add, TestContext.Current.CancellationToken); 34var outputTask = DevTunnelCli.PumpAsync(outputReader, _ => Assert.Fail("No stdout was written."), TestContext.Current.CancellationToken); 35var errorTask = DevTunnelCli.PumpAsync(errorReader, line => errorLine.TrySetResult(line), TestContext.Current.CancellationToken); 50var pump = DevTunnelCli.PumpAsync(reader, _ => Assert.Fail("No output was written."), cts.Token);