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)
344var run = new TrayWatchStream(monitor, new TestProcessIdentityProvider(), time, logger).RunAsync((json, _) => 462var run = new TrayWatchStream(monitor, new TestProcessIdentityProvider(), new FakeTimeProvider(), logger).RunAsync((json, _) => 529var run = new TrayWatchStream(monitor, new TestProcessIdentityProvider(), time, logger).RunAsync((json, _) => 648var result = await new TrayWatchStream(monitor, new TestProcessIdentityProvider(), new FakeTimeProvider(), logger).RunAsync((json, _) => 771var run = new TrayWatchStream(monitor, new TestProcessIdentityProvider(), new FakeTimeProvider(), logger) 996=> 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 }); 354time.Advance(TrayWatchStream.DashboardLookupTimeout); 406time.Advance(TrayWatchStream.DashboardLookupTimeout); 411time.Advance(TrayWatchStream.DashboardRetryInterval); 519if (count % TrayWatchStream.MaximumConcurrentDashboardLookups == 0) 535for (var second = 0; second < TrayWatchStream.DashboardSnapshotTimeout.TotalSeconds; second++) 537Assert.Equal((second + 1) * TrayWatchStream.MaximumConcurrentDashboardLookups, await batches.Reader.ReadAsync().AsTask().DefaultTimeout()); 546Assert.InRange(calls, TrayWatchStream.MaximumConcurrentDashboardLookups, TrayCliProtocol.MaximumAppHosts - 1); 549Assert.True(TrayWatchStream.DashboardSnapshotTimeout < TrayCliProtocol.LivenessTimeout); 564var blockedCount = saturateSlots ? TrayWatchStream.MaximumConcurrentDashboardLookups : 1; 591time.Advance(TrayWatchStream.DashboardLookupTimeout); 995private static TrayWatchStream CreateStream(TestAuxiliaryBackchannelMonitor monitor, TimeProvider time, TestProcessIdentityProvider? identity = null)