Channel

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>

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

68var connectionChanges = Channel.CreateUnbounded<bool>(new UnboundedChannelOptions

Backchannel\ResourceSnapshotWatcher.cs (2)

21private readonly Channel<bool>? _updateSignal; 214var updateSignal = _updateSignal ?? throw new InvalidOperationException("Resource update buffering was not enabled for this watcher.");

Commands\PsCommand.cs (1)

186var updates = Channel.CreateUnbounded<PsFollowUpdate>(new UnboundedChannelOptions

Diagnostics\FileLoggerProvider.cs (2)

24private readonly Channel<string>? _channel; 93private static Channel<string> CreateChannel() =>

Interaction\ExtensionInteractionService.cs (1)

37private 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,

Backchannel\ResourceSnapshotWatcherTests.cs (1)

447var source = Channel.CreateUnbounded<ResourceSnapshot>();

Commands\AgentMcpCommandTests.cs (2)

357var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>(); 445var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>();

Commands\LogsCommandTests.cs (1)

1435var logLines = Channel.CreateUnbounded<string>();

TestServices\TestAuxiliaryBackchannelMonitor.cs (1)

15private readonly Channel<bool> _connectionChanges = Channel.CreateUnbounded<bool>();

ActivityNotifier.cs (1)

16private readonly Channel<Activity> _activityChannel = Channel.CreateUnbounded<Activity>();

MetricsChannel.cs (1)

17private readonly Channel<string> _channel = Channel.CreateBounded<string>(new BoundedChannelOptions(10_000)

Api\TelemetryApiService.cs (1)

528var signal = Channel.CreateBounded<bool>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });

Components\Pages\ConsoleLogs.razor.cs (1)

141private readonly Channel<LogEntryToWrite> _logEntryChannel = Channel.CreateUnbounded<LogEntryToWrite>(new UnboundedChannelOptions

Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (6)

222var channel = Channel.CreateBounded<OtlpSpan>(new BoundedChannelOptions(1000) 279var channel = Channel.CreateBounded<OtlpLogEntry>(new BoundedChannelOptions(1000) 424private sealed class SpanWatcher(WatchSpansRequest request, Channel<OtlpSpan> channel) 427public Channel<OtlpSpan> Channel => channel; 430private sealed class LogWatcher(WatchLogsRequest request, Channel<OtlpLogEntry> channel) 433public 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 = []; 570ImmutableHashSet<Channel<IReadOnlyList<ResourceViewModelChange>>> resourceChannels = []; 681foreach (var channel in resourceChannels) 758foreach (var channel in _outgoingInteractionChannels) 855var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 900var channel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>( 952var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(

ServiceClient\SqliteResourceRepository.cs (13)

src\Shared\ChannelExtensions.cs (1)

26this Channel<T> channel,

Telemetry\DashboardTelemetrySender.cs (1)

18private readonly Channel<(OperationContext, Func<HttpClient, Func<OperationContextProperty, object>, Task>)> _channel;

Dialogs\ManageDataDialogTests.cs (2)

42var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 253var resourcesChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();

Interactions\InteractionsProviderTests.cs (20)

Pages\ConsoleLogsTerminalTests.cs (20)

Pages\ConsoleLogsTests.cs (38)

Pages\ResourcesTests.cs (2)

87var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 497var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();

tests\Shared\TestDashboardClient.cs (16)

17private readonly Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? _consoleLogsChannelProvider; 18private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 19private readonly Func<Channel<WatchInteractionsResponseUpdate>>? _interactionChannelProvider; 20private readonly Channel<ResourceCommandResponseViewModel>? _resourceCommandsChannel; 22private readonly Channel<WatchInteractionsRequestUpdate>? _sendInteractionUpdateChannel; 40Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? consoleLogsChannelProvider = null, 41Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 42Func<Channel<WatchInteractionsResponseUpdate>>? interactionChannelProvider = null, 43Channel<ResourceCommandResponseViewModel>? resourceCommandsChannel = null, 45Channel<WatchInteractionsRequestUpdate>? sendInteractionUpdateChannel = null, 95var channel = _consoleLogsChannelProvider(resourceName); 110var channel = _consoleLogsChannelProvider(resourceName); 131var channel = _resourceChannelProvider(); 135async static IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken) 151var channel = _interactionChannelProvider(); 155async static IAsyncEnumerable<WatchInteractionsResponseUpdate> BuildSubscription(Channel<WatchInteractionsResponseUpdate> channel, [EnumeratorCancellation] CancellationToken cancellationToken)

tests\Shared\TestDashboardTelemetrySender.cs (1)

12public Channel<OperationContext> ContextChannel { get; } = Channel.CreateUnbounded<OperationContext>();

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>>();

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\TestDashboardClient.cs (16)

17private readonly Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? _consoleLogsChannelProvider; 18private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 19private readonly Func<Channel<WatchInteractionsResponseUpdate>>? _interactionChannelProvider; 20private readonly Channel<ResourceCommandResponseViewModel>? _resourceCommandsChannel; 22private readonly Channel<WatchInteractionsRequestUpdate>? _sendInteractionUpdateChannel; 40Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? consoleLogsChannelProvider = null, 41Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 42Func<Channel<WatchInteractionsResponseUpdate>>? interactionChannelProvider = null, 43Channel<ResourceCommandResponseViewModel>? resourceCommandsChannel = null, 45Channel<WatchInteractionsRequestUpdate>? sendInteractionUpdateChannel = null, 95var channel = _consoleLogsChannelProvider(resourceName); 110var channel = _consoleLogsChannelProvider(resourceName); 131var channel = _resourceChannelProvider(); 135async static IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken) 151var channel = _interactionChannelProvider(); 155async static IAsyncEnumerable<WatchInteractionsResponseUpdate> BuildSubscription(Channel<WatchInteractionsResponseUpdate> channel, [EnumeratorCancellation] CancellationToken cancellationToken)

tests\Shared\TestDashboardTelemetrySender.cs (1)

12public Channel<OperationContext> ContextChannel { get; } = Channel.CreateUnbounded<OperationContext>();

ApplicationModel\ResourceLoggerService.cs (3)

228var channel = Channel.CreateUnbounded<LogSubscriber>(); 317var channel = Channel.CreateUnbounded<IReadOnlyList<LogLine>>(); 460var channel = Channel.CreateUnbounded<LogEntry>();

ApplicationModel\ResourceNotificationService.cs (1)

763var channel = Channel.CreateUnbounded<ResourceEvent>();

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

1632var 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)

57private 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)

648var channel = Channel.CreateUnbounded<Interaction>();

Pipelines\PipelineActivityReporter.cs (1)

523internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();

src\Shared\ChannelExtensions.cs (1)

26this Channel<T> channel,

AzureProvisioningController.cs (1)

128private readonly Channel<QueuedOperation> _operationChannel = Channel.CreateUnbounded<QueuedOperation>(new UnboundedChannelOptions

tests\Shared\TestInteractionService.cs (1)

23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();

tests\Shared\TestInteractionService.cs (1)

23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();

tests\Shared\TestInteractionService.cs (1)

23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();

FoundryExtensions.cs (1)

356var progressChannel = Channel.CreateUnbounded<float>();

tests\Shared\TestInteractionService.cs (1)

23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();

Cli\CliOrphanDetectorTests.cs (2)

146var processRunningChannel = Channel.CreateUnbounded<int>(); 216var processRunningChannel = Channel.CreateUnbounded<int>();

Dashboard\DashboardEventHandlersTests.cs (2)

41var logChannel = Channel.CreateUnbounded<WriteContext>(); 94var logChannel = Channel.CreateUnbounded<WriteContext>();

Dashboard\DashboardServiceTests.cs (1)

40var getConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>();

Dcp\DcpExecutorTests.cs (9)

Dcp\TestKubernetesService.cs (7)

28private readonly List<Channel<(WatchEventType, CustomResource)>> _watchChannels = []; 108foreach (var c in _watchChannels) 135foreach (var c in _watchChannels) 153foreach (var c in _watchChannels) 184foreach (var c in _watchChannels) 283var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>(); 434foreach (var c in _watchChannels)

DistributedApplicationTests.cs (1)

1209var 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)

136var commandResourcesChannel = Channel.CreateUnbounded<string>(); 173var 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)

23public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();

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);

DcpUpstreamAdapter.cs (1)

63private readonly Channel<ReadOnlyMemory<byte>> _outputChannel;

Commands\Test\MTP\TestApplicationActionQueue.cs (1)

13private readonly Channel<ParallelizableTestModuleGroupWithSequentialInnerModules> _channel;

src\sdk\src\Cli\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)

13private readonly Channel<ParallelizableTestModuleGroupWithSequentialInnerModules> _channel;

UI\SpectreBuildParametersSelectionPrompt.cs (1)

115private readonly Channel<ConsoleKeyInfo> _channel = Channel.CreateUnbounded<ConsoleKeyInfo>();

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),

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;

Connection\DirectTlsConnectionListener.cs (1)

45private readonly Channel<DirectTlsConnection> _readyConnections;

Internal\NamedPipeConnectionListener.cs (1)

26private readonly Channel<ConnectionContext> _acceptedQueue;

HubConnection.cs (1)

1919var 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)

32private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });

Internal\ChannelBasedSemaphore.cs (1)

13private readonly Channel<int> _channel;

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)

133private readonly Channel<T?> _channel;

AssemblyDependency\Node\RarNodeBuildEngine.cs (2)

46private readonly Channel<BuildEventArgs> _eventChannel; 47private readonly Channel<int> _eventCountChannel;

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),

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),

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),

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),

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),

Util\FSWGen.cs (1)

14Channel<System.IO.FileSystemEventArgs>? _channel;

Aspire\AspireServiceFactory.cs (1)

129var outputChannel = Channel.CreateUnbounded<OutputLine>(s_outputChannelOptions);

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

134var updates = Channel.CreateBounded<ChatResponseUpdate>(1);

ServiceEndpointResolverTests.cs (1)

266var channel = Channel.CreateUnbounded<ServiceEndpointResolverResult>();

Transforms\RowShufflingTransformer.cs (3)

490private readonly Channel<int> _toProduceChannel; 491private readonly Channel<int> _toConsumeChannel; 555public static void PostAssert<T>(Channel<T> target, T item)

AsyncSweeper.cs (1)

171private readonly Channel<ParameterSetWithId> _paramChannel;

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),

ProducerConsumer.cs (1)

20private readonly Channel<Data> _channel = Channel.CreateUnbounded<Data>();

Program.cs (1)

282var channel = Channel.CreateUnbounded<string>();

System\Diagnostics\Process.Multiplexing.cs (1)

541Channel<ProcessOutputLine> channel = Channel.CreateBounded<ProcessOutputLine>(0);

System\IO\FileSystemWatcher.Linux.cs (1)

1003private readonly Channel<WatcherEvent> _eventQueue;

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)

56private readonly Channel<WriteQueueEntry> _writeChannel;

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\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)