5 types derived from Channel
System.Threading.Channels (5)
System\Threading\Channels\BoundedChannel.cs (1)
14internal sealed class BoundedChannel<T> : Channel<T>, IDebugEnumerable<T>
System\Threading\Channels\RendezvousChannel.cs (1)
14internal sealed class RendezvousChannel<T> : Channel<T>
System\Threading\Channels\SingleConsumerUnboundedChannel.cs (1)
18internal sealed class SingleConsumerUnboundedChannel<T> : Channel<T>, IDebugEnumerable<T>
System\Threading\Channels\UnboundedChannel.cs (1)
15internal sealed class UnboundedChannel<T> : Channel<T>, IDebugEnumerable<T>
System\Threading\Channels\UnboundedPriorityChannel.cs (1)
19internal sealed class UnboundedPrioritizedChannel<T> : Channel<T>, IDebugEnumerable<T>
464 references to Channel
aspire (11)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
85var connectionChanges = Channel.CreateUnbounded<bool>(new UnboundedChannelOptions
Backchannel\ResourceSnapshotWatcher.cs (2)
21private readonly Channel<bool>? _updateSignal; 237var updateSignal = _updateSignal ?? throw new InvalidOperationException("Resource update buffering was not enabled for this watcher.");
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 (2)
26private readonly Channel<string>? _channel; 158private static Channel<string> CreateChannel() =>
Interaction\ExtensionInteractionService.cs (1)
43private readonly Channel<Func<Task>> _extensionTaskChannel;
Projects\ProjectLocator.cs (1)
194var channel = Channel.CreateUnbounded<AppHostProjectCandidate>(new UnboundedChannelOptions
src\Shared\ChannelExtensions.cs (1)
26this Channel<T> channel,
aspire-tray (1)
NativeSmokeHarness.cs (1)
419private 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>>(); 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.Confluent.Kafka (1)
MetricsChannel.cs (1)
17private readonly Channel<string> _channel = Channel.CreateBounded<string>(new BoundedChannelOptions(10_000)
Aspire.Dashboard (31)
Api\TelemetryApiService.cs (1)
528var signal = Channel.CreateBounded<bool>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
Components\Pages\ConsoleLogs.razor.cs (1)
145private readonly Channel<IReadOnlyList<LogEntryToWrite>> _logEntryChannel = Channel.CreateUnbounded<IReadOnlyList<LogEntryToWrite>>(new UnboundedChannelOptions
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (6)
221var channel = Channel.CreateBounded<OtlpSpan>(new BoundedChannelOptions(1000) 278var channel = Channel.CreateBounded<OtlpLogEntry>(new BoundedChannelOptions(1000) 423private sealed class SpanWatcher(WatchSpansRequest request, Channel<OtlpSpan> channel) 426public Channel<OtlpSpan> Channel => channel; 429private sealed class LogWatcher(WatchLogsRequest request, Channel<OtlpLogEntry> channel) 432public Channel<OtlpLogEntry> Channel => channel;
ServiceClient\DashboardClient.cs (9)
61private readonly Channel<WatchInteractionsRequestUpdate> _incomingInteractionChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 73private ImmutableHashSet<Channel<IReadOnlyList<ResourceViewModelChange>>> _outgoingResourceChannels = []; 74private ImmutableHashSet<Channel<WatchInteractionsResponseUpdate>> _outgoingInteractionChannels = []; 615ImmutableHashSet<Channel<IReadOnlyList<ResourceViewModelChange>>> resourceChannels = []; 729foreach (var channel in resourceChannels) 806foreach (var channel in _outgoingInteractionChannels) 916var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 961var channel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>( 1013var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(
ServiceClient\SqliteResourceRepository.cs (13)
27private ImmutableHashSet<Channel<IReadOnlyList<ResourceViewModelChange>>> _resourceChannels = []; 28private readonly Dictionary<string, ImmutableHashSet<Channel<IReadOnlyList<ResourceLogLine>>>> _consoleChannels = new(StringComparers.ResourceName); 73var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(new UnboundedChannelOptions 119Channel<IReadOnlyList<ResourceLogLine>> channel; 321Channel<IReadOnlyList<ResourceLogLine>>[] channels; 388foreach (var channel in channels) 479Channel<IReadOnlyList<ResourceViewModelChange>> channel, 505Channel<IReadOnlyList<ResourceViewModelChange>>[] channels; 510foreach (var channel in channels) 532Channel<IReadOnlyList<ResourceViewModelChange>>[] resourceChannels; 533Channel<IReadOnlyList<ResourceLogLine>>[] consoleChannels; 540foreach (var channel in resourceChannels) 544foreach (var channel in consoleChannels)
src\Shared\ChannelExtensions.cs (1)
26this Channel<T> channel,
Aspire.Dashboard.Components.Tests (140)
Controls\TerminalDisconnectedBannerTests.cs (3)
30var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 104var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 159var updates = 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 (1)
104var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Layout\MainLayoutTerminalTests.cs (2)
29var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 86var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>();
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 (20)
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>(); 464var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 493var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 519var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 564var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 626var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 655var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 684var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 733var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 773var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 816var 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 (1)
27var logs = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>();
Pages\ConsoleLogsTests.cs (38)
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>>(); 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>>(); 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>>(); 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 (3)
262var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 543var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 1006var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Pages\TerminalsTests.cs (2)
496var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 592var updates = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Pages\TerminalWindowTests.cs (8)
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\TerminalSetupHelpers.cs (1)
26Func<Channel<WatchTerminalsUpdate>>? terminalChannelProvider = null,
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>();
tests\Shared\TestDashboardClient.cs (18)
18private readonly Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? _consoleLogsChannelProvider; 19private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 20private readonly Func<Channel<WatchInteractionsResponseUpdate>>? _interactionChannelProvider; 21private readonly Func<Channel<WatchTerminalsUpdate>>? _terminalChannelProvider; 24private readonly Channel<ResourceCommandResponseViewModel>? _resourceCommandsChannel; 26private readonly Channel<WatchInteractionsRequestUpdate>? _sendInteractionUpdateChannel; 59Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? consoleLogsChannelProvider = null, 60Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 61Func<Channel<WatchInteractionsResponseUpdate>>? interactionChannelProvider = null, 62Channel<ResourceCommandResponseViewModel>? resourceCommandsChannel = null, 64Channel<WatchInteractionsRequestUpdate>? sendInteractionUpdateChannel = null, 68Func<Channel<WatchTerminalsUpdate>>? terminalChannelProvider = null, 169var channel = _consoleLogsChannelProvider(resourceName); 184var channel = _consoleLogsChannelProvider(resourceName); 210var channel = _resourceChannelProvider(); 215async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken) 238var channel = _interactionChannelProvider(); 242async static IAsyncEnumerable<WatchInteractionsResponseUpdate> BuildSubscription(Channel<WatchInteractionsResponseUpdate> channel, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Dashboard.Playwright.Tests (27)
Integration\Playwright\Infrastructure\TestTerminalConnectionResolver.cs (1)
18private readonly Channel<TestTerminalConnection> _connections = Channel.CreateUnbounded<TestTerminalConnection>();
Integration\Playwright\TerminalDockTests.cs (8)
422private async Task<(Channel<WatchTerminalsUpdate> Updates, Channel<string> Closes)> OpenDockAsync(IPage page) 458private Channel<WatchTerminalsUpdate> _updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 459private Channel<string> _closes = Channel.CreateUnbounded<string>(); 473public async Task<(Channel<WatchTerminalsUpdate> Updates, Channel<string> Closes)> StartSessionAsync() 476var updates = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 477var closes = Channel.CreateUnbounded<string>();
tests\Shared\TestDashboardClient.cs (18)
18private readonly Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? _consoleLogsChannelProvider; 19private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 20private readonly Func<Channel<WatchInteractionsResponseUpdate>>? _interactionChannelProvider; 21private readonly Func<Channel<WatchTerminalsUpdate>>? _terminalChannelProvider; 24private readonly Channel<ResourceCommandResponseViewModel>? _resourceCommandsChannel; 26private readonly Channel<WatchInteractionsRequestUpdate>? _sendInteractionUpdateChannel; 59Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? consoleLogsChannelProvider = null, 60Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 61Func<Channel<WatchInteractionsResponseUpdate>>? interactionChannelProvider = null, 62Channel<ResourceCommandResponseViewModel>? resourceCommandsChannel = null, 64Channel<WatchInteractionsRequestUpdate>? sendInteractionUpdateChannel = null, 68Func<Channel<WatchTerminalsUpdate>>? terminalChannelProvider = null, 169var channel = _consoleLogsChannelProvider(resourceName); 184var channel = _consoleLogsChannelProvider(resourceName); 210var channel = _resourceChannelProvider(); 215async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken) 238var channel = _interactionChannelProvider(); 242async static IAsyncEnumerable<WatchInteractionsResponseUpdate> BuildSubscription(Channel<WatchInteractionsResponseUpdate> channel, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Dashboard.Tests (51)
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 (17)
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>(); 1159var channel = Channel.CreateUnbounded<WatchTerminalsUpdate>(); 1210var channel = Channel.CreateUnbounded<WatchTerminalsUpdate>();
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>();
tests\Shared\TestDashboardClient.cs (18)
18private readonly Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? _consoleLogsChannelProvider; 19private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 20private readonly Func<Channel<WatchInteractionsResponseUpdate>>? _interactionChannelProvider; 21private readonly Func<Channel<WatchTerminalsUpdate>>? _terminalChannelProvider; 24private readonly Channel<ResourceCommandResponseViewModel>? _resourceCommandsChannel; 26private readonly Channel<WatchInteractionsRequestUpdate>? _sendInteractionUpdateChannel; 59Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? consoleLogsChannelProvider = null, 60Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 61Func<Channel<WatchInteractionsResponseUpdate>>? interactionChannelProvider = null, 62Channel<ResourceCommandResponseViewModel>? resourceCommandsChannel = null, 64Channel<WatchInteractionsRequestUpdate>? sendInteractionUpdateChannel = null, 68Func<Channel<WatchTerminalsUpdate>>? terminalChannelProvider = null, 169var channel = _consoleLogsChannelProvider(resourceName); 184var channel = _consoleLogsChannelProvider(resourceName); 210var channel = _resourceChannelProvider(); 215async IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken) 238var channel = _interactionChannelProvider(); 242async static IAsyncEnumerable<WatchInteractionsResponseUpdate> BuildSubscription(Channel<WatchInteractionsResponseUpdate> channel, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Hosting (27)
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 (5)
55private ImmutableHashSet<Channel<TerminalUpdate>> _outgoingChannels = []; 307var channel = Channel.CreateBounded<TerminalUpdate>(new BoundedChannelOptions(_dockUpdateBufferCapacity) 369private void Unsubscribe(Channel<TerminalUpdate> channel) 433foreach (var channel in _outgoingChannels) 499foreach (var channel in _outgoingChannels)
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1654var channel = Channel.CreateUnbounded<ResourceLogLine>(new UnboundedChannelOptions
Backchannel\BackchannelLoggerProvider.cs (6)
13private readonly Dictionary<int, Channel<BackchannelLogEntry>> _subscribers = []; 23internal (List<BackchannelLogEntry> Snapshot, int SubscriberId, Channel<BackchannelLogEntry> Channel) Subscribe() 25var channel = Channel.CreateUnbounded<BackchannelLogEntry>(); 39if (_subscribers.Remove(subscriberId, out var channel)) 59foreach (var subscriber in _subscribers.Values) 75foreach (var subscriber in _subscribers.Values)
Dashboard\ResourcePublisher.cs (4)
23private ImmutableHashSet<Channel<ResourceSnapshotChange>> _outgoingChannels = []; 49var channel = Channel.CreateUnbounded<ResourceSnapshotChange>( 86ImmutableHashSet<Channel<ResourceSnapshotChange>> channels; 104foreach (var channel in channels)
Dcp\DcpResourceWatcher.cs (1)
65private readonly Channel<LogInformationEntry> _logInformationChannel = Channel.CreateUnbounded<LogInformationEntry>(
Dcp\KubernetesService.cs (1)
309var channel = Channel.CreateUnbounded<(WatchEventType, T)>(new UnboundedChannelOptions
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>();
src\Shared\ChannelExtensions.cs (1)
26this Channel<T> channel,
Aspire.Hosting.Azure (1)
AzureProvisioningController.cs (1)
127private 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.Native.Core (1)
Diagnostics\OperationEventSource.cs (1)
79private readonly Channel<OperationEvent> _channel;
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.Native.Server (1)
Api\PipelineApi.cs (1)
68private Channel<NativePublishingActivity> _activities = Channel.CreateBounded<NativePublishingActivity>(8192);
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 (46)
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 (12)
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>(); 3884private static async Task<LogStreamPipes> GetStreamPipesAsync(Channel<(string Type, Pipe Pipe)> logStreamPipesChannel) 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\KubernetesServiceTests.cs (1)
149var requestsStarted = Channel.CreateUnbounded<string>();
Dcp\TestKubernetesService.cs (7)
34private readonly List<Channel<(WatchEventType, CustomResource)>> _watchChannels = []; 139foreach (var c in _watchChannels) 166foreach (var c in _watchChannels) 184foreach (var c in _watchChannels) 215foreach (var c in _watchChannels) 314var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>(); 483foreach (var c in _watchChannels)
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>>();
Terminals\TerminalServiceTests.cs (7)
59var channel = Assert.Single(GetOutgoingChannels(service)); 140var channel = Assert.Single(GetOutgoingChannels(service)); 416var channel = Assert.Single(GetOutgoingChannels(service)); 451var channel = Assert.Single(GetOutgoingChannels(service)); 575var channel = Assert.Single(GetOutgoingChannels(service)); 1065private static ImmutableHashSet<Channel<TerminalUpdate>> GetOutgoingChannels(TerminalService service) 1070return (ImmutableHashSet<Channel<TerminalUpdate>>)field.GetValue(service)!;
tests\Shared\TestInteractionService.cs (1)
29public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.TestUtilities (5)
Utils\Grpc\TestAsyncStreamReader.cs (1)
11private readonly Channel<T> _channel;
Utils\Grpc\TestServerStreamWriter.cs (1)
12private readonly Channel<T> _channel;
Utils\TestConsoleLogsService.cs (3)
12private readonly Func<string, Channel<IReadOnlyList<LogEntry>>>? _getConsoleLogsChannel; 14public TestConsoleLogsService(Func<string, Channel<IReadOnlyList<LogEntry>>>? getConsoleLogsChannel = null) 26var channel = _getConsoleLogsChannel(resourceName);
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
63private readonly Channel<ReadOnlyMemory<byte>> _outputChannel;
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)
13private readonly Channel<ParallelizableTestModuleGroupWithSequentialInnerModules> _channel;
dotnet-watch (1)
UI\SpectreBuildParametersSelectionPrompt.cs (1)
115private readonly Channel<ConsoleKeyInfo> _channel = Channel.CreateUnbounded<ConsoleKeyInfo>();
GenerateDocumentationAndConfigFiles (7)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (4)
253var channel = Channel.CreateUnbounded<TItem>(); 307/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 326var channel = Channel.CreateUnbounded<TItem>(new() 336static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)),
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)
44var channel = Channel.CreateBounded<T>(1024); 70public static void CompletesChannel<T>(this Task task, Channel<T> channel) 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http2\Http2FrameWriter.cs (2)
23/// Since a connection has multiple streams, this class maintains a <see cref="Channel{T}"/> (i.e. bounded queue) 86private readonly Channel<Http2OutputProducer> _channel;
Internal\WebTransport\WebTransportSession.cs (1)
26private readonly Channel<WebTransportStream> _pendingStreams;
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
Internal\NamedPipeConnectionListener.cs (1)
26private readonly Channel<ConnectionContext> _acceptedQueue;
Microsoft.AspNetCore.SignalR.Client.Core (5)
HubConnection.cs (1)
1926var invocationMessageChannel = Channel.CreateUnbounded<InvocationMessage>(_receiveLoopOptions);
HubConnectionExtensions.StreamAsChannelAsync.cs (2)
277var outputChannel = Channel.CreateUnbounded<TResult>(); 287private static async Task RunChannel<TResult>(ChannelReader<object?> inputChannel, Channel<TResult> outputChannel)
Internal\InvocationRequest.cs (1)
88private readonly Channel<object?> _channel = Channel.CreateUnbounded<object?>();
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
34private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
Microsoft.AspNetCore.SignalR.Core (3)
Internal\ChannelBasedSemaphore.cs (1)
13private readonly Channel<int> _channel;
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
34private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
StreamTracker.cs (1)
133private readonly Channel<T?> _channel;
Microsoft.Build.Tasks.Core (2)
AssemblyDependency\Node\RarNodeBuildEngine.cs (2)
46private readonly Channel<BuildEventArgs> _eventChannel; 47private readonly Channel<int> _eventCountChannel;
Microsoft.CodeAnalysis.Analyzers (6)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (3)
253var channel = Channel.CreateUnbounded<TItem>(); 307/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)
44var channel = Channel.CreateBounded<T>(1024); 70public static void CompletesChannel<T>(this Task task, Channel<T> channel) 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.AnalyzerUtilities (6)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (3)
253var channel = Channel.CreateUnbounded<TItem>(); 307/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)
44var channel = Channel.CreateBounded<T>(1024); 70public static void CompletesChannel<T>(this Task task, Channel<T> channel) 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.CodeStyle (6)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (3)
253var channel = Channel.CreateUnbounded<TItem>(); 307/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)
44var channel = Channel.CreateBounded<T>(1024); 70public static void CompletesChannel<T>(this Task task, Channel<T> channel) 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.ResxSourceGenerator (6)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (3)
253var channel = Channel.CreateUnbounded<TItem>(); 307/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)
44var channel = Channel.CreateBounded<T>(1024); 70public static void CompletesChannel<T>(this Task task, Channel<T> channel) 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.CodeAnalysis.Workspaces (7)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (4)
253var channel = Channel.CreateUnbounded<TItem>(); 307/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 326var channel = Channel.CreateUnbounded<TItem>(new() 336static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)),
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)
44var channel = Channel.CreateBounded<T>(1024); 70public static void CompletesChannel<T>(this Task task, Channel<T> channel) 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
Microsoft.DotNet.HotReload.Utils.Generator (1)
Util\FSWGen.cs (1)
14Channel<System.IO.FileSystemEventArgs>? _channel;
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 (3)
Transforms\RowShufflingTransformer.cs (3)
490private readonly Channel<int> _toProduceChannel; 491private readonly Channel<int> _toConsumeChannel; 555public static void PostAssert<T>(Channel<T> target, T item)
Microsoft.ML.Sweeper (1)
AsyncSweeper.cs (1)
171private readonly Channel<ParameterSetWithId> _paramChannel;
Roslyn.Diagnostics.Analyzers (6)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (3)
253var channel = Channel.CreateUnbounded<TItem>(); 307/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)
44var channel = Channel.CreateBounded<T>(1024); 70public static void CompletesChannel<T>(this Task task, Channel<T> channel) 75static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),
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)
1003private readonly Channel<WatcherEvent> _eventQueue;
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
56private readonly Channel<WriteQueueEntry> _writeChannel;
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)
101private readonly Channel<object> _acceptQueue;
System.Threading.Channels (7)
System\Threading\Channels\Channel.cs (5)
11public static Channel<T> CreateUnbounded<T>() => 19public static Channel<T> CreateUnbounded<T>(UnboundedChannelOptions options) 40public static Channel<T> CreateBounded<T>(int capacity) => 50public static Channel<T> CreateBounded<T>(BoundedChannelOptions options) => 59public static Channel<T> CreateBounded<T>(BoundedChannelOptions options, Action<T>? itemDropped)
System\Threading\Channels\Channel.netcoreapp.cs (2)
17public static Channel<T> CreateUnboundedPrioritized<T>() => 29public static Channel<T> CreateUnboundedPrioritized<T>(UnboundedPrioritizedChannelOptions<T> options)