356 references to Channel
aspire (8)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
85var connectionChanges = Channel.CreateUnbounded<bool>(new UnboundedChannelOptions
Backchannel\ResourceSnapshotWatcher.cs (1)
41_updateSignal = Channel.CreateBounded<bool>(
Backchannel\TrayWatchStream.cs (2)
39var updates = Channel.CreateBounded<Update>(new BoundedChannelOptions(1) 45var healthChanges = Channel.CreateBounded<bool>(new BoundedChannelOptions(1)
Commands\PsCommand.cs (1)
233var updates = Channel.CreateUnbounded<PsFollowUpdate>(new UnboundedChannelOptions
Diagnostics\FileLoggerProvider.cs (1)
102Channel.CreateBounded<string>(new BoundedChannelOptions(MaxQueuedMessages)
Interaction\ExtensionInteractionService.cs (1)
61_extensionTaskChannel = Channel.CreateUnbounded<Func<Task>>(new UnboundedChannelOptions
Projects\ProjectLocator.cs (1)
194var channel = Channel.CreateUnbounded<AppHostProjectCandidate>(new UnboundedChannelOptions
aspire-tray (1)
NativeSmokeHarness.cs (1)
541private readonly Channel<AppHostSnapshot> _snapshots = Channel.CreateUnbounded<AppHostSnapshot>(
Aspire.Cli.Tests (21)
Backchannel\ResourceSnapshotWatcherTests.cs (1)
536var source = Channel.CreateUnbounded<ResourceSnapshot>();
Backchannel\TrayWatchStreamTests.cs (14)
112var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 382var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 507var batches = Channel.CreateUnbounded<int>(); 561var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 562var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 666var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 667var resourceUpdates = Channel.CreateUnbounded<ResourceSnapshot>(); 668var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 763var resourceUpdates = Channel.CreateUnbounded<ResourceSnapshot>(); 764var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 803var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 804var messages = Channel.CreateUnbounded<TrayWatchMessage>(); 865var snapshots = Channel.CreateUnbounded<IReadOnlyList<IAppHostAuxiliaryBackchannel>>(); 866var 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.Confluent.Kafka (1)
MetricsChannel.cs (1)
17private readonly Channel<string> _channel = Channel.CreateBounded<string>(new BoundedChannelOptions(10_000)
Aspire.Dashboard (10)
Api\TelemetryApiService.cs (1)
528var signal = Channel.CreateBounded<bool>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
Components\Pages\ConsoleLogs.razor.cs (1)
145private readonly Channel<LogEntryToWrite> _logEntryChannel = Channel.CreateUnbounded<LogEntryToWrite>(new UnboundedChannelOptions
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)
221var channel = Channel.CreateBounded<OtlpSpan>(new BoundedChannelOptions(1000) 278var channel = Channel.CreateBounded<OtlpLogEntry>(new BoundedChannelOptions(1000)
ServiceClient\DashboardClient.cs (4)
61private readonly Channel<WatchInteractionsRequestUpdate> _incomingInteractionChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 916var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 961var channel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>( 1013var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(
ServiceClient\SqliteResourceRepository.cs (2)
73var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(new UnboundedChannelOptions 135channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(new UnboundedChannelOptions
Aspire.Dashboard.Components.Tests (163)
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\TerminalWindowButtonTests.cs (2)
224var checkedKeys = Channel.CreateUnbounded<string[]>(); 314var failedKeys = Channel.CreateUnbounded<string[]>();
Dialogs\ManageDataDialogTests.cs (2)
42var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 256var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Interactions\InteractionsProviderTests.cs (23)
61var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 87var liveInteractionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 88var liveRequestsChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 89var selectedInteractionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 90var selectedRequestsChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 139var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 140var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 203var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 253var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 254var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 311var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 312var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 374var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 375var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 444var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 445var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 483var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 484var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 560var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 561var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 617var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 618var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 678var 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)
31resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 58resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 104var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Layout\MainLayoutTerminalTests.cs (6)
29var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 38resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 86var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 91resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 175terminalChannelProvider: () => Channel.CreateUnbounded<WatchTerminalsUpdate>(), 176resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>());
Layout\TerminalDockInitializationTests.cs (2)
24var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 25var processed = Channel.CreateUnbounded<WatchTerminalsUpdate>();
Layout\TerminalDockTelemetryTests.cs (1)
30var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>();
Layout\TerminalDockTests.cs (19)
29var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 64var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 133var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 156var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 214var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 269var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 310var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 344var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 395var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 431var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 460var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 486var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 531var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 593var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 622var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 651var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 700var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 740var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 783var 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\ResourcesTests.cs (24)
56], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 157var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 182var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 232resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>, 264var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 363var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 416var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 545var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 659var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [resource], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 705var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 733var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 761var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 792var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 913resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1008var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1141var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1168var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1197var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1227var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1259var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1341var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1403var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1447var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 1486resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>,
Pages\TerminalsTests.cs (8)
34resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 74resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 98resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()) 133resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 449resourceChannelProvider: () => Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>()); 478var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 574var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 641resourceChannelProvider: () => 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)
72context.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)
25public Channel<Activity> ActivityChannel { get; } = Channel.CreateUnbounded<Activity>(); 26public Channel<TestDashboardTelemetryLog> LogChannel { get; } = Channel.CreateUnbounded<TestDashboardTelemetryLog>(); 116public Channel<TestDashboardTelemetryLog> LogChannel { get; } = Channel.CreateUnbounded<TestDashboardTelemetryLog>();
Aspire.Dashboard.Tests (41)
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>>();
Integration\Playwright\Infrastructure\TestTerminalConnectionResolver.cs (1)
18private readonly Channel<TestTerminalConnection> _connections = Channel.CreateUnbounded<TestTerminalConnection>();
Integration\Playwright\TerminalDockTests.cs (4)
458private Channel<WatchTerminalsUpdate> _updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 459private Channel<string> _closes = Channel.CreateUnbounded<string>(); 476var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 477var closes = Channel.CreateUnbounded<string>();
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)
25public Channel<Activity> ActivityChannel { get; } = Channel.CreateUnbounded<Activity>(); 26public Channel<TestDashboardTelemetryLog> LogChannel { get; } = Channel.CreateUnbounded<TestDashboardTelemetryLog>(); 116public Channel<TestDashboardTelemetryLog> LogChannel { get; } = Channel.CreateUnbounded<TestDashboardTelemetryLog>();
Aspire.Hosting (13)
ApplicationModel\ResourceLoggerService.cs (3)
228var channel = Channel.CreateUnbounded<LogSubscriber>(); 317var channel = Channel.CreateUnbounded<IReadOnlyList<LogLine>>(); 460var channel = Channel.CreateUnbounded<LogEntry>();
ApplicationModel\ResourceNotificationService.cs (1)
802var channel = Channel.CreateUnbounded<ResourceEvent>();
ApplicationModel\TerminalService.cs (1)
307var channel = Channel.CreateBounded<TerminalUpdate>(new BoundedChannelOptions(_dockUpdateBufferCapacity)
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1654var channel = Channel.CreateUnbounded<ResourceLogLine>(new UnboundedChannelOptions
Backchannel\BackchannelLoggerProvider.cs (1)
25var channel = Channel.CreateUnbounded<BackchannelLogEntry>();
Dashboard\ResourcePublisher.cs (1)
49var channel = Channel.CreateUnbounded<ResourceSnapshotChange>(
Dcp\DcpResourceWatcher.cs (1)
65private readonly Channel<LogInformationEntry> _logInformationChannel = Channel.CreateUnbounded<LogInformationEntry>(
Dcp\ResourceLogSource.cs (1)
48var channel = Channel.CreateUnbounded<ResourceLogEntry>(new UnboundedChannelOptions
Devcontainers\DevcontainerSettingsWriter.cs (1)
27private readonly Channel<PortForwardEntry> _portUpdates = Channel.CreateUnbounded<PortForwardEntry>(new UnboundedChannelOptions
InteractionService.cs (1)
691var channel = Channel.CreateUnbounded<Interaction>();
Pipelines\PipelineActivityReporter.cs (1)
521internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Azure (1)
AzureProvisioningController.cs (1)
125private readonly Channel<QueuedOperation> _operationChannel = Channel.CreateUnbounded<QueuedOperation>(new UnboundedChannelOptions
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 (1)
DevTunnelMonitor.cs (1)
35private readonly Channel<Operation> _operations = Channel.CreateUnbounded<Operation>(new()
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.RemoteHost (1)
src\Shared\ChildProcess.cs (1)
694var lines = Channel.CreateBounded<OutputLine>(new BoundedChannelOptions(256)
Aspire.Hosting.RemoteHost.Tests (1)
tests\Shared\TestInteractionService.cs (1)
29public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.Tests (31)
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>>(); 1735var logs = Channel.CreateUnbounded<WriteContext>(); 1815var logs = Channel.CreateUnbounded<WriteContext>();
Dcp\DcpExecutorTests.cs (11)
202var endpointEventsProcessed = Channel.CreateUnbounded<bool>(); 491var channel = Channel.CreateUnbounded<string>(); 1939var logStreamPipesChannel = Channel.CreateUnbounded<(string Type, Pipe Pipe)>(); 2530var followStdErrPipeChannel = Channel.CreateUnbounded<Pipe>(); 3008var changes = Channel.CreateUnbounded<OnResourceChangedContext>(); 3076var changes = Channel.CreateUnbounded<OnResourceChangedContext>(); 4469var allocatedPortChannel = Channel.CreateUnbounded<int>(); 4470var connectionStringAvailableChannel = Channel.CreateUnbounded<IResource>(); 4545var connectionStringAvailableChannel = Channel.CreateUnbounded<IResource>(); 4622var resolvedUrlChannel = Channel.CreateUnbounded<string?>(); 4669var resolvedUrlChannel = Channel.CreateUnbounded<string?>();
Dcp\TestKubernetesService.cs (1)
314var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>();
DistributedApplicationTests.cs (1)
1213var 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>(); 899var updates = Channel.CreateUnbounded<Interaction>(); 952var updates = Channel.CreateUnbounded<Interaction>();
ResourceCommandServiceTests.cs (2)
137var commandResourcesChannel = Channel.CreateUnbounded<string>(); 174var 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.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
86_outputChannel = Channel.CreateBounded<ReadOnlyMemory<byte>>(
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-aot (1)
parent\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)
42_channel = Channel.CreateUnbounded<ParallelizableTestModuleGroupWithSequentialInnerModules>(new UnboundedChannelOptions { SingleReader = false, SingleWriter = false });
dotnet-watch (1)
UI\SpectreBuildParametersSelectionPrompt.cs (1)
115private readonly Channel<ConsoleKeyInfo> _channel = Channel.CreateUnbounded<ConsoleKeyInfo>();
GenerateDocumentationAndConfigFiles (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
44var channel = Channel.CreateBounded<T>(1024);
Microsoft.AspNetCore.Server.Kestrel.Core (2)
Internal\Http2\Http2FrameWriter.cs (1)
153_channel = Channel.CreateBounded<Http2OutputProducer>(new BoundedChannelOptions(maxStreamsPerConnection)
Internal\WebTransport\WebTransportSession.cs (1)
52_pendingStreams = Channel.CreateUnbounded<WebTransportStream>();
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
Internal\NamedPipeConnectionListener.cs (1)
52_acceptedQueue = Channel.CreateBounded<ConnectionContext>(new BoundedChannelOptions(capacity: 1));
Microsoft.AspNetCore.SignalR.Client.Core (4)
HubConnection.cs (1)
1926var invocationMessageChannel = Channel.CreateUnbounded<InvocationMessage>(_receiveLoopOptions);
HubConnectionExtensions.StreamAsChannelAsync.cs (1)
277var outputChannel = Channel.CreateUnbounded<TResult>();
Internal\InvocationRequest.cs (1)
88private readonly Channel<object?> _channel = Channel.CreateUnbounded<object?>();
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
32private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
Microsoft.AspNetCore.SignalR.Core (3)
Internal\ChannelBasedSemaphore.cs (1)
17_channel = Channel.CreateBounded<int>(maxCapacity);
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
32private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
StreamTracker.cs (1)
137_channel = Channel.CreateBounded<T?>(streamBufferCapacity);
Microsoft.Build.Tasks.Core (2)
AssemblyDependency\Node\RarNodeBuildEngine.cs (2)
57_eventChannel = Channel.CreateUnbounded<BuildEventArgs>(new UnboundedChannelOptions 62_eventCountChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions
Microsoft.CodeAnalysis.Analyzers (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
44var channel = Channel.CreateBounded<T>(1024);
Microsoft.CodeAnalysis.AnalyzerUtilities (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
44var channel = Channel.CreateBounded<T>(1024);
Microsoft.CodeAnalysis.CodeStyle (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
44var channel = Channel.CreateBounded<T>(1024);
Microsoft.CodeAnalysis.ResxSourceGenerator (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
44var channel = Channel.CreateBounded<T>(1024);
Microsoft.CodeAnalysis.Workspaces (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
44var channel = Channel.CreateBounded<T>(1024);
Microsoft.DotNet.HotReload.Utils.Generator (1)
Util\FSWGen.cs (1)
19_channel = Channel.CreateUnbounded<System.IO.FileSystemEventArgs> (new UnboundedChannelOptions { SingleReader = true, AllowSynchronousContinuations = true});
Microsoft.DotNet.HotReload.Watch (1)
Aspire\AspireServiceFactory.cs (1)
129var outputChannel = Channel.CreateUnbounded<OutputLine>(s_outputChannelOptions);
Microsoft.Extensions.AI (1)
ChatCompletion\AnonymousDelegatingChatClient.cs (1)
134var updates = Channel.CreateBounded<ChatResponseUpdate>(1);
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
266var channel = Channel.CreateUnbounded<ServiceEndpointResolverResult>();
Microsoft.ML.Data (2)
Transforms\RowShufflingTransformer.cs (2)
544_toConsumeChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions { SingleWriter = true }); 545_toProduceChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions { SingleWriter = true });
Microsoft.ML.Sweeper (1)
AsyncSweeper.cs (1)
211_paramChannel = Channel.CreateUnbounded<ParameterSetWithId>(
Roslyn.Diagnostics.Analyzers (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
44var channel = Channel.CreateBounded<T>(1024);
Stress.ApiService (2)
ProducerConsumer.cs (1)
20private readonly Channel<Data> _channel = Channel.CreateUnbounded<Data>();
Program.cs (1)
338var channel = Channel.CreateUnbounded<string>();
System.Diagnostics.Process (1)
System\Diagnostics\Process.Multiplexing.cs (1)
541Channel<ProcessOutputLine> channel = Channel.CreateBounded<ProcessOutputLine>(0);
System.IO.FileSystem.Watcher (1)
System\IO\FileSystemWatcher.Linux.cs (1)
1038_eventQueue = Channel.CreateUnbounded<WatcherEvent>(new UnboundedChannelOptions() { AllowSynchronousContinuations = false, SingleReader = true });
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
153_writeChannel = Channel.CreateUnbounded<WriteQueueEntry>(s_channelOptions);
System.Net.Quic (2)
System\Net\Quic\QuicConnection.cs (1)
150private readonly Channel<QuicStream> _acceptQueue = Channel.CreateUnbounded<QuicStream>(new UnboundedChannelOptions()
System\Net\Quic\QuicListener.cs (1)
143_acceptQueue = Channel.CreateUnbounded<object>();