7 instantiations of TrayWatchStream
aspire (1)
Commands\PsCommand.cs (1)
149var stream = new TrayWatchStream(_backchannelMonitor, _processIdentityProvider, _timeProvider, _logger);
Aspire.Cli.Tests (6)
Backchannel\TrayWatchStreamTests.cs (6)
402var run = new TrayWatchStream(monitor, new TestProcessIdentityProvider(), time, logger).RunAsync((json, _) => 520var run = new TrayWatchStream(monitor, new TestProcessIdentityProvider(), new FakeTimeProvider(), logger).RunAsync((json, _) => 587var run = new TrayWatchStream(monitor, new TestProcessIdentityProvider(), time, logger).RunAsync((json, _) => 706var result = await new TrayWatchStream(monitor, new TestProcessIdentityProvider(), new FakeTimeProvider(), logger).RunAsync((json, _) => 829var run = new TrayWatchStream(monitor, new TestProcessIdentityProvider(), new FakeTimeProvider(), logger) 1054=> new(monitor, identity ?? new TestProcessIdentityProvider(), time, NullLogger.Instance);
14 references to TrayWatchStream
aspire (1)
Commands\PsCommand.cs (1)
149var stream = new TrayWatchStream(_backchannelMonitor, _processIdentityProvider, _timeProvider, _logger);
Aspire.Cli.Tests (13)
Backchannel\TrayWatchStreamTests.cs (13)
29var stream = CreateStream(monitor, time); 118var stream = CreateStream(monitor, new FakeTimeProvider(), new TestProcessIdentityProvider { GetStartTime = pid => pid == 10 ? 1000 : null }); 412time.Advance(TrayWatchStream.DashboardLookupTimeout); 464time.Advance(TrayWatchStream.DashboardLookupTimeout); 469time.Advance(TrayWatchStream.DashboardRetryInterval); 577if (count % TrayWatchStream.MaximumConcurrentDashboardLookups == 0) 593for (var second = 0; second < TrayWatchStream.DashboardSnapshotTimeout.TotalSeconds; second++) 595Assert.Equal((second + 1) * TrayWatchStream.MaximumConcurrentDashboardLookups, await batches.Reader.ReadAsync().AsTask().DefaultTimeout()); 604Assert.InRange(calls, TrayWatchStream.MaximumConcurrentDashboardLookups, TrayCliProtocol.MaximumAppHosts - 1); 607Assert.True(TrayWatchStream.DashboardSnapshotTimeout < TrayCliProtocol.LivenessTimeout); 622var blockedCount = saturateSlots ? TrayWatchStream.MaximumConcurrentDashboardLookups : 1; 649time.Advance(TrayWatchStream.DashboardLookupTimeout); 1053private static TrayWatchStream CreateStream(TestAuxiliaryBackchannelMonitor monitor, TimeProvider time, TestProcessIdentityProvider? identity = null)