358 references to CreateUnbounded
Aspire.Cli.Tests (21)
Backchannel\ResourceSnapshotWatcherTests.cs (1)
536var source = Channel.CreateUnbounded<ResourceSnapshot>();
Backchannel\TrayWatchStreamTests.cs (14)
112var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 440var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 565var batches = Channel.CreateUnbounded<int>(); 619var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 620var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 724var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 725var resourceUpdates = Channel.CreateUnbounded<ResourceSnapshot>(); 726var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 821var resourceUpdates = Channel.CreateUnbounded<ResourceSnapshot>(); 822var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 861var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 862var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 923var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 924var messages = Channel.CreateUnbounded<TrayWatchMessage>();
Commands\AgentMcpCommandTests.cs (4)
1048var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>(); 1245var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>(); 1305var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>(); 1344var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>();
Commands\LogsCommandTests.cs (1)
1435var logLines = Channel.CreateUnbounded<string>();
TestServices\TestAuxiliaryBackchannelMonitor.cs (1)
14private readonly Channel<bool> _connectionChanges = Channel.CreateUnbounded<bool>();
Aspire.Components.Common.TestUtilities (1)
ActivityNotifier.cs (1)
16private readonly Channel<Activity> _activityChannel = Channel.CreateUnbounded<Activity>();
Aspire.Dashboard (1)
ServiceClient\DashboardClient.cs (1)
61private readonly Channel<WatchInteractionsRequestUpdate> _incomingInteractionChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>();
Aspire.Dashboard.Components.Tests (223)
Controls\ApplicationSummaryTests.cs (4)
30var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 107var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 179var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 201var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Controls\ResourceActionsTests.cs (4)
36resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 77resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 100resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 116resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>);
Controls\TerminalDisconnectedBannerTests.cs (5)
30var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 67resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(), 104var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 147resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 159var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Controls\TerminalViewTests.cs (1)
627resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>());
Controls\TerminalWindowButtonTests.cs (2)
224var checkedKeys = Channel.CreateUnbounded<string[]>(); 314var failedKeys = Channel.CreateUnbounded<string[]>();
Dialogs\ManageDataDialogTests.cs (3)
38var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 74var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 288var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Interactions\InteractionsProviderTests.cs (26)
60var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 86var liveInteractionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 87var liveRequestsChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 88var selectedInteractionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 89var selectedRequestsChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 138var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 139var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 202var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 252var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 253var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 310var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 311var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 372var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 419var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 420var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 476var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 477var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 546var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 547var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 585var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 586var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 662var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 663var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 719var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 720var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 780var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>();
Interactions\InteractionsProviderTests.Terminal.cs (6)
27var updates = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 28var requests = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 29var shown = Channel.CreateUnbounded<(object? Content, DialogParameters Parameters)>(); 86var updates = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 87var requests = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 88var shown = Channel.CreateUnbounded<(object? Content, DialogParameters Parameters)>();
Layout\MainLayoutResourceTerminalsTests.cs (3)
30resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 57resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 103var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Layout\MainLayoutTerminalTests.cs (6)
28var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 37resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 85var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 90resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 174terminalChannelProvider: () => Channel.CreateUnbounded<WatchTerminalsUpdate>(), 175resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>());
Layout\MainLayoutTests.cs (3)
66dashboardClient: new TestDashboardClient(isEnabled: true, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>)); 87resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>())); 108resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()),
Layout\NavigationAvailabilityProviderTests.cs (2)
51var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 59var reported = Channel.CreateUnbounded<NavigationAvailability>();
Layout\ResourcesLayoutTests.cs (37)
33var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 61var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 108var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 189var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 230var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 275var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 302var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 329var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 380var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 413var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 457resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>)); 475var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 510var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 541var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 589resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>)); 640resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>)); 681var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 707var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 749var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 783var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 810var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 853var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 876var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 911var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 956var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 985var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1015var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1069var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1104var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1159var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1198var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1226var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1259var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1400var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1459var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1477var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1496var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Layout\TerminalDockInitializationTests.cs (2)
24var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 25var processed = Channel.CreateUnbounded<WatchTerminalsUpdate>();
Layout\TerminalDockTelemetryTests.cs (1)
29var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>();
Layout\TerminalDockTests.cs (21)
29var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 64var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 131var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 154var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 212var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 267var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 308var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 342var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 393var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 429var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 462var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 491var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 517var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 562var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 624var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 653var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 682var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 731var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 757var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 797var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 840var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>();
Layout\TerminalDockWindowTrackingTests.cs (4)
29var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 88var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 174var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 177var started = Channel.CreateUnbounded<bool>();
Pages\ConsoleLogsTerminalTests.cs (2)
27var logs = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 30resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(),
Pages\ConsoleLogsTests.cs (43)
40var subscribedResourceNamesChannel = Channel.CreateUnbounded<string>(); 41var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 42var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 90var subscribedResourceNamesChannel = Channel.CreateUnbounded<string>(); 91var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 92var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 151consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 180var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 181var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 269var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 270var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 321var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 322var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 368var liveConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 369var repositoryConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 370var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 413consoleLogsChannelProvider: _ => Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(), 414resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 431var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 432var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 472var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 473var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 498var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 499var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 547var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 548var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 596var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 597var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 661var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 662var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 699var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 700var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 754var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 755var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 795var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 796var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 871consoleLogsChannelProvider: _ => Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(), 872resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 904var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 905var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 906var resourceCommandChannel = Channel.CreateUnbounded<ResourceCommandResponseViewModel>(); 963var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 964var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Pages\ResourceOverviewPersistenceTests.cs (1)
34var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Pages\ResourceOverviewTerminalTests.cs (1)
30resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>);
Pages\ResourcesTests.cs (24)
57initialResources: [resource], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>)); 77], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 176var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 201var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 251resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 283var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 382var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 437var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 564var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 678var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [resource], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 729var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 757var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 785var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 815resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 912var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1047var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1074var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1103var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1133var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1165var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1247var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1309var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1353var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1392resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>,
Pages\TerminalsTests.cs (8)
141resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 181resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 205resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 240resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 556resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 585var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 681var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 763resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>());
Pages\TerminalWindowTests.cs (9)
100terminalChannelProvider: () => Channel.CreateUnbounded<WatchTerminalsUpdate>()); 295var terminals = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 441var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 457var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 481var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 505var firstUpdates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 506var secondUpdates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 542var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 580var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>();
Shared\ResourceSetupHelpers.cs (1)
103context.Services.AddSingleton<IDashboardClient>(dashboardClient ?? new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>));
Shared\TerminalSetupHelpers.cs (1)
29resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(),
tests\Shared\DashboardTelemetryFixture.cs (3)
27public Channel<Activity> ActivityChannel { get; } = Channel.CreateUnbounded<Activity>(); 28public Channel<TestDashboardTelemetryLog> LogChannel { get; } = Channel.CreateUnbounded<TestDashboardTelemetryLog>(); 142public Channel<TestDashboardTelemetryLog> LogChannel { get; } = Channel.CreateUnbounded<TestDashboardTelemetryLog>();
Aspire.Dashboard.Playwright.Tests (6)
Integration\Playwright\Infrastructure\TestTerminalConnectionResolver.cs (1)
18private readonly Channel<TestTerminalConnection> _connections = Channel.CreateUnbounded<TestTerminalConnection>();
Integration\Playwright\TerminalDockTests.cs (5)
466private Channel<WatchTerminalsUpdate> _updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 467private Channel<string> _closes = Channel.CreateUnbounded<string>(); 468private readonly Channel<IReadOnlyList<ResourceViewModelChange>> _resourceUpdates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 503var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 504var closes = Channel.CreateUnbounded<string>();
Aspire.Dashboard.Tests (36)
ChannelExtensionsTests.cs (6)
58var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 82var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 106var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 107var resultChannel = Channel.CreateUnbounded<IReadOnlyList<IReadOnlyList<string>>>(); 150var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 151var resultChannel = Channel.CreateUnbounded<IReadOnlyList<IReadOnlyList<string>>>();
Integration\DashboardClientAuthTests.cs (1)
171public Channel<ReceivedCallInfo<ApplicationInformationRequest>> ResourceInformationCallsChannel { get; } = Channel.CreateUnbounded<ReceivedCallInfo<ApplicationInformationRequest>>();
Model\DashboardClientTests.cs (20)
43var channel = Channel.CreateUnbounded<TerminalServerFrame>(); 123var channel = Channel.CreateUnbounded<TerminalServerFrame>(); 146var channel = Channel.CreateUnbounded<TerminalServerFrame>(); 170var channel = Channel.CreateUnbounded<TerminalServerFrame>(); 483var updates = Channel.CreateUnbounded<WatchResourcesUpdate>(); 531var resources = Channel.CreateUnbounded<WatchResourcesUpdate>(); 532var firstInteractions = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 533var secondInteractions = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 593var first = Channel.CreateUnbounded<WatchResourcesUpdate>(); 594var second = Channel.CreateUnbounded<WatchResourcesUpdate>(); 595var third = Channel.CreateUnbounded<WatchResourcesUpdate>(); 596var subscriptionsStarted = Channel.CreateUnbounded<int>(); 1102var first = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 1103var second = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 1104var disposed = Channel.CreateUnbounded<bool>(); 1108ResourceUpdatesChannel = Channel.CreateUnbounded<WatchResourcesUpdate>().Reader, 1159var channel = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 1163ResourceUpdatesChannel = Channel.CreateUnbounded<WatchResourcesUpdate>().Reader, 1210var channel = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 1216ResourceUpdatesChannel = Channel.CreateUnbounded<WatchResourcesUpdate>().Reader,
ResourceOutgoingPeerResolverTests.cs (5)
285var sourceChannel = Channel.CreateUnbounded<ResourceViewModelChange>(); 286var resultChannel = Channel.CreateUnbounded<(int ChangeCount, long Timestamp)>(); 364var sourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 383var sourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 400var sourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
TelemetryRepositoryTests\LogTests.cs (1)
966var resultChannel = Channel.CreateUnbounded<int>();
tests\Shared\DashboardTelemetryFixture.cs (3)
27public Channel<Activity> ActivityChannel { get; } = Channel.CreateUnbounded<Activity>(); 28public Channel<TestDashboardTelemetryLog> LogChannel { get; } = Channel.CreateUnbounded<TestDashboardTelemetryLog>(); 142public Channel<TestDashboardTelemetryLog> LogChannel { get; } = Channel.CreateUnbounded<TestDashboardTelemetryLog>();
Aspire.Hosting (7)
ApplicationModel\ResourceLoggerService.cs (3)
228var channel = Channel.CreateUnbounded<LogSubscriber>(); 317var channel = Channel.CreateUnbounded<IReadOnlyList<LogLine>>(); 460var channel = Channel.CreateUnbounded<LogEntry>();
ApplicationModel\ResourceNotificationService.cs (1)
823var channel = Channel.CreateUnbounded<ResourceEvent>();
Backchannel\BackchannelLoggerProvider.cs (1)
25var channel = Channel.CreateUnbounded<BackchannelLogEntry>();
InteractionService.cs (1)
698var channel = Channel.CreateUnbounded<Interaction>();
Pipelines\PipelineActivityReporter.cs (1)
521internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Azure.Tests (1)
tests\Shared\TestInteractionService.cs (1)
29public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.Browsers.Tests (1)
tests\Shared\TestInteractionService.cs (1)
29public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.DevTunnels.Tests (2)
TestDevTunnelTimeProvider.cs (1)
11public Channel<TimeSpan> ScheduledDelays { get; } = Channel.CreateUnbounded<TimeSpan>();
tests\Shared\TestInteractionService.cs (1)
29public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.Foundry (1)
FoundryExtensions.cs (1)
470var progressChannel = Channel.CreateUnbounded<float>();
Aspire.Hosting.Native.Core.Tests (3)
SocketConnectionListenerTests.cs (2)
28var connected = Channel.CreateUnbounded<bool>(); 83var connected = Channel.CreateUnbounded<bool>();
TestServices\RecordingBackchannelRpc.cs (1)
13private readonly Channel<bool> _connections = Channel.CreateUnbounded<bool>();
Aspire.Hosting.RemoteHost.Tests (1)
tests\Shared\TestInteractionService.cs (1)
29public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.Tests (32)
Cli\CliOrphanDetectorTests.cs (2)
146var processRunningChannel = Channel.CreateUnbounded<int>(); 216var processRunningChannel = Channel.CreateUnbounded<int>();
Dashboard\DashboardEventHandlersTests.cs (2)
43var logChannel = Channel.CreateUnbounded<WriteContext>(); 96var logChannel = Channel.CreateUnbounded<WriteContext>();
Dashboard\DashboardServiceTests.cs (3)
45var getConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 1780var logs = Channel.CreateUnbounded<WriteContext>(); 1860var logs = Channel.CreateUnbounded<WriteContext>();
Dcp\DcpExecutorTests.cs (11)
203var endpointEventsProcessed = Channel.CreateUnbounded<bool>(); 492var channel = Channel.CreateUnbounded<string>(); 1940var logStreamPipesChannel = Channel.CreateUnbounded<(string Type, Pipe Pipe)>(); 2531var followStdErrPipeChannel = Channel.CreateUnbounded<Pipe>(); 3009var changes = Channel.CreateUnbounded<OnResourceChangedContext>(); 3077var changes = Channel.CreateUnbounded<OnResourceChangedContext>(); 4470var allocatedPortChannel = Channel.CreateUnbounded<int>(); 4471var connectionStringAvailableChannel = Channel.CreateUnbounded<IResource>(); 4546var connectionStringAvailableChannel = Channel.CreateUnbounded<IResource>(); 4623var resolvedUrlChannel = Channel.CreateUnbounded<string?>(); 4670var resolvedUrlChannel = Channel.CreateUnbounded<string?>();
Dcp\KubernetesServiceTests.cs (1)
190var requestsStarted = Channel.CreateUnbounded<string>();
Dcp\TestKubernetesService.cs (1)
319var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>();
DistributedApplicationTests.cs (1)
1268var beforeResourceStartedEvents = Channel.CreateUnbounded<BeforeResourceStartedEvent>();
Health\ResourceHealthCheckServiceTests.cs (2)
148var channel = Channel.CreateUnbounded<ResourceReadyEvent>(); 293var channel = Channel.CreateUnbounded<DateTimeOffset>();
InteractionServiceTests.cs (3)
126var updates = Channel.CreateUnbounded<Interaction>(); 1003var updates = Channel.CreateUnbounded<Interaction>(); 1056var updates = Channel.CreateUnbounded<Interaction>();
ResourceCommandServiceTests.cs (2)
138var commandResourcesChannel = Channel.CreateUnbounded<string>(); 175var commandResourcesChannel = Channel.CreateUnbounded<string>();
ResourceLoggerServiceTests.cs (3)
263var consoleLogsChannel0 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 267var consoleLogsChannel1 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 482var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>();
tests\Shared\TestInteractionService.cs (1)
29public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.TestUtilities (2)
Utils\Grpc\TestAsyncStreamReader.cs (1)
18_channel = Channel.CreateUnbounded<T>();
Utils\Grpc\TestServerStreamWriter.cs (1)
20_channel = Channel.CreateUnbounded<T>();
Aspire.Tray.Tests (5)
Helpers\TestAppHostClient.cs (5)
12private readonly Channel<AppHostSnapshot> _snapshots = Channel.CreateUnbounded<AppHostSnapshot>(); 13private readonly Channel<AppHostId> _started = Channel.CreateUnbounded<AppHostId>(); 14private readonly Channel<AppHostId> _finished = Channel.CreateUnbounded<AppHostId>(); 16private readonly Channel<string> _starting = Channel.CreateUnbounded<string>(); 17private readonly Channel<string> _finishedStarts = Channel.CreateUnbounded<string>();
dotnet-watch (1)
UI\SpectreBuildParametersSelectionPrompt.cs (1)
115private readonly Channel<ConsoleKeyInfo> _channel = Channel.CreateUnbounded<ConsoleKeyInfo>();
GenerateDocumentationAndConfigFiles (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\WebTransport\WebTransportSession.cs (1)
52_pendingStreams = Channel.CreateUnbounded<WebTransportStream>();
Microsoft.AspNetCore.SignalR.Client.Core (2)
HubConnectionExtensions.StreamAsChannelAsync.cs (1)
277var outputChannel = Channel.CreateUnbounded<TResult>();
Internal\InvocationRequest.cs (1)
88private readonly Channel<object?> _channel = Channel.CreateUnbounded<object?>();
Microsoft.CodeAnalysis.Analyzers (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.CodeAnalysis.CodeStyle (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.CodeAnalysis.Workspaces (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
266var channel = Channel.CreateUnbounded<ServiceEndpointResolverResult>();
Roslyn.Diagnostics.Analyzers (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
253var channel = Channel.CreateUnbounded<TItem>();
Stress.ApiService (2)
ProducerConsumer.cs (1)
20private readonly Channel<Data> _channel = Channel.CreateUnbounded<Data>();
Program.cs (1)
338var channel = Channel.CreateUnbounded<string>();
System.Net.Quic (1)
System\Net\Quic\QuicListener.cs (1)
143_acceptQueue = Channel.CreateUnbounded<object>();