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>

Interaction\ExtensionInteractionService.cs (1)

20private readonly Channel<Func<Task>> _extensionTaskChannel;

Hosting\CliOrphanDetectorTests.cs (3)

39var stopSignalChannel = Channel.CreateUnbounded<bool>(); 60var stopSignalChannel = Channel.CreateUnbounded<bool>(); 61var processRunningChannel = Channel.CreateUnbounded<int>();

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)

ServiceClient\DashboardClient.cs (8)

51private readonly Channel<WatchInteractionsRequestUpdate> _incomingInteractionChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 61private ImmutableHashSet<Channel<IReadOnlyList<ResourceViewModelChange>>> _outgoingResourceChannels = []; 62private ImmutableHashSet<Channel<WatchInteractionsResponseUpdate>> _outgoingInteractionChannels = []; 419foreach (var channel in _outgoingResourceChannels) 492foreach (var channel in _outgoingInteractionChannels) 565var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 610var channel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>( 656var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(

src\Shared\ChannelExtensions.cs (1)

26this Channel<T> channel,

Telemetry\DashboardTelemetrySender.cs (1)

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

Interactions\InteractionsProviderTests.cs (7)

53var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 77var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 121var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 169var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 170var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 225var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 226var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>();

Pages\ConsoleLogsTests.cs (23)

Pages\ResourcesTests.cs (2)

36var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 318var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();

Shared\TestDashboardClient.cs (15)

14private readonly Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? _consoleLogsChannelProvider; 15private readonly Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? _resourceChannelProvider; 16private readonly Func<Channel<WatchInteractionsResponseUpdate>>? _interactionChannelProvider; 17private readonly Channel<ResourceCommandResponseViewModel>? _resourceCommandsChannel; 18private readonly Channel<WatchInteractionsRequestUpdate>? _sendInteractionUpdateChannel; 27Func<string, Channel<IReadOnlyList<ResourceLogLine>>>? consoleLogsChannelProvider = null, 28Func<Channel<IReadOnlyList<ResourceViewModelChange>>>? resourceChannelProvider = null, 29Func<Channel<WatchInteractionsResponseUpdate>>? interactionChannelProvider = null, 30Channel<ResourceCommandResponseViewModel>? resourceCommandsChannel = null, 31Channel<WatchInteractionsRequestUpdate>? sendInteractionUpdateChannel = null, 65var channel = _consoleLogsChannelProvider(resourceName); 85var channel = _resourceChannelProvider(); 89async static IAsyncEnumerable<IReadOnlyList<ResourceViewModelChange>> BuildSubscription(Channel<IReadOnlyList<ResourceViewModelChange>> channel, [EnumeratorCancellation] CancellationToken cancellationToken) 105var channel = _interactionChannelProvider(); 109async 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)

19var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 43var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 67var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 68var resultChannel = Channel.CreateUnbounded<IReadOnlyList<IReadOnlyList<string>>>(); 111var channel = Channel.CreateUnbounded<IReadOnlyList<string>>(); 112var resultChannel = Channel.CreateUnbounded<IReadOnlyList<IReadOnlyList<string>>>();

Integration\DashboardClientAuthTests.cs (1)

156public Channel<ReceivedCallInfo<ApplicationInformationRequest>> ApplicationInformationCallsChannel { get; } = Channel.CreateUnbounded<ReceivedCallInfo<ApplicationInformationRequest>>();

ResourceOutgoingPeerResolverTests.cs (2)

125var sourceChannel = Channel.CreateUnbounded<ResourceViewModelChange>(); 126var resultChannel = Channel.CreateUnbounded<int>();

TelemetryRepositoryTests\LogTests.cs (1)

712var resultChannel = Channel.CreateUnbounded<int>();

tests\Shared\TestDashboardTelemetrySender.cs (1)

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

ApplicationModel\InteractionService.cs (1)

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

ApplicationModel\ResourceLoggerService.cs (3)

223var channel = Channel.CreateUnbounded<LogSubscriber>(); 297var channel = Channel.CreateUnbounded<IReadOnlyList<LogLine>>(); 419var channel = Channel.CreateUnbounded<LogEntry>();

ApplicationModel\ResourceNotificationService.cs (1)

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

Backchannel\AppHostRpcTarget.cs (3)

27private readonly TaskCompletionSource<Channel<BackchannelLogEntry>> _logChannelTcs = new(); 29public void RegisterLogChannel(Channel<BackchannelLogEntry> channel) 37var channel = await _logChannelTcs.Task.WaitAsync(cancellationToken).ConfigureAwait(false);

Backchannel\BackchannelLoggerProvider.cs (2)

12private readonly Channel<BackchannelLogEntry> _channel = Channel.CreateUnbounded<BackchannelLogEntry>(); 62internal class BackchannelLogger(string categoryName, Channel<BackchannelLogEntry> channel) : ILogger

Dashboard\ResourcePublisher.cs (4)

23private ImmutableHashSet<Channel<ResourceSnapshotChange>> _outgoingChannels = []; 49var channel = Channel.CreateUnbounded<ResourceSnapshotChange>( 86ImmutableHashSet<Channel<ResourceSnapshotChange>> channels; 104foreach (var channel in channels)

Dcp\DcpExecutor.cs (1)

73private readonly Channel<LogInformationEntry> _logInformationChannel = Channel.CreateUnbounded<LogInformationEntry>(

Dcp\ResourceLogSource.cs (1)

28var channel = Channel.CreateUnbounded<LogEntry>(new UnboundedChannelOptions

Publishing\PublishingActivityProgressReporter.cs (1)

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

src\Shared\ChannelExtensions.cs (1)

26this Channel<T> channel,

Dashboard\DashboardLifecycleHookTests.cs (1)

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

Dashboard\DashboardServiceTests.cs (1)

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

Dcp\DcpExecutorTests.cs (3)

71var channel = Channel.CreateUnbounded<string>(); 568var logStreamPipesChannel = Channel.CreateUnbounded<(string Type, Pipe Pipe)>(); 732private static async Task<LogStreamPipes> GetStreamPipesAsync(Channel<(string Type, Pipe Pipe)> logStreamPipesChannel)

Dcp\TestKubernetesService.cs (5)

27private readonly List<Channel<(WatchEventType, CustomResource)>> _watchChannels = []; 84foreach (var c in _watchChannels) 97foreach (var c in _watchChannels) 134var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>(); 239foreach (var c in _watchChannels)

DistributedApplicationTests.cs (1)

619var beforeResourceStartedEvents = Channel.CreateUnbounded<BeforeResourceStartedEvent>();

Health\ResourceHealthCheckServiceTests.cs (2)

151var channel = Channel.CreateUnbounded<ResourceReadyEvent>(); 294var channel = Channel.CreateUnbounded<DateTimeOffset>();

InteractionServiceTests.cs (1)

122var updates = Channel.CreateUnbounded<Interaction>();

ResourceCommandServiceTests.cs (1)

59var commandResourcesChannel = Channel.CreateUnbounded<string>();

ResourceLoggerServiceTests.cs (2)

262var consoleLogsChannel0 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 266var consoleLogsChannel1 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>();

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

VersionChecking\VersionCheckServiceTests.cs (1)

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

UploadSample.cs (4)

44var channel = Channel.CreateUnbounded<string>(); 60var channel_one = Channel.CreateBounded<int>(2); 61var channel_two = Channel.CreateBounded<int>(2); 85var channel = Channel.CreateUnbounded<string>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (4)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new() 353static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)),

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (3)

82internal readonly Channel<KeyValuePair<Http3SettingType, long>> _serverReceivedSettings; 990public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.CreateUnbounded<ConnectionContext>(new UnboundedChannelOptions 996public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions

TestTransport\InMemoryTransportFactory.cs (1)

15private readonly Channel<ConnectionContext> _acceptQueue = Channel.CreateUnbounded<ConnectionContext>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

src\Shared\EventSource.Testing\TestCounterListener.cs (2)

20private readonly Dictionary<string, Channel<double>> _counters = new Dictionary<string, Channel<double>>();

src\Shared\EventSource.Testing\TestCounterListener.cs (2)

20private readonly Dictionary<string, Channel<double>> _counters = new Dictionary<string, Channel<double>>();

TestWebSocketConnectionFeature.cs (2)

40var clientToServer = Channel.CreateUnbounded<WebSocketMessage>(); 41var serverToClient = Channel.CreateUnbounded<WebSocketMessage>();

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;

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (3)

82internal readonly Channel<KeyValuePair<Http3SettingType, long>> _serverReceivedSettings; 990public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.CreateUnbounded<ConnectionContext>(new UnboundedChannelOptions 996public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions

Internal\NamedPipeConnectionListener.cs (1)

26private readonly Channel<ConnectionContext> _acceptedQueue;

HubConnection.cs (1)

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

81private readonly Channel<object?> _channel = Channel.CreateUnbounded<object?>();

src\SignalR\common\Shared\MessageBuffer.cs (1)

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

HubConnectionTests.cs (2)

799var channelWriter = Channel.CreateBounded<string>(5); 2925private readonly Channel<(SendOrPostCallback, object)> _taskQueue = Channel.CreateUnbounded<(SendOrPostCallback, object)>();

HubConnectionTests.Tracing.cs (7)

35var serverChannel = Channel.CreateUnbounded<Activity>(); 36var clientChannel = Channel.CreateUnbounded<Activity>(); 229var serverChannel = Channel.CreateUnbounded<Activity>(); 374var serverChannel = Channel.CreateUnbounded<Activity>(); 477var serverChannel = Channel.CreateUnbounded<Activity>(); 573var serverChannel = Channel.CreateUnbounded<Activity>(); 663var serverChannel = Channel.CreateUnbounded<Activity>();

Hubs.cs (3)

227var channel = Channel.CreateUnbounded<int>(); 252var output = Channel.CreateUnbounded<string>(); 276var output = Channel.CreateUnbounded<int>();

HubConnectionTests.cs (8)

438var channel = Channel.CreateUnbounded<int>(); 478var channel = Channel.CreateUnbounded<int>(); 509var channel = Channel.CreateUnbounded<object>(); 554var channel = Channel.CreateUnbounded<int>(); 586var channel = Channel.CreateUnbounded<int>(); 611var channel = Channel.CreateUnbounded<int>(); 645var channel = Channel.CreateUnbounded<int>(); 678var channel = Channel.CreateUnbounded<int>();

HubServerProxyGeneratorTests.cs (8)

Internal\ChannelBasedSemaphore.cs (1)

13private readonly Channel<int> _channel;

src\SignalR\common\Shared\MessageBuffer.cs (1)

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

StreamTracker.cs (1)

108private readonly Channel<T?> _channel;

DefaultHubDispatcherBenchmark.cs (4)

136var channel = Channel.CreateUnbounded<int>(); 144var channel = Channel.CreateUnbounded<int>(); 152var channel = Channel.CreateUnbounded<int>(); 160var channel = Channel.CreateUnbounded<int>();

HubConnectionHandlerTests.Activity.cs (8)

HubConnectionHandlerTests.cs (1)

4749var channel = Channel.CreateBounded<int>(10);

HubConnectionHandlerTestUtils\Hubs.cs (12)

NativeAotTests.cs (4)

79var channel = Channel.CreateBounded<string>(10); 112var channelShorts = Channel.CreateBounded<short>(10); 249Channel<string> output = Channel.CreateUnbounded<string>(); 282Channel<char> output = Channel.CreateUnbounded<char>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (4)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new() 353static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)),

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

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

ServiceEndpointResolverTests.cs (1)

264var 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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()

TestHub.cs (3)

62var channel = Channel.CreateUnbounded<string>(); 72var channel = Channel.CreateUnbounded<string>(); 100var channel = Channel.CreateUnbounded<int>();

Hubs\Streaming.cs (1)

32var channel = Channel.CreateUnbounded<int>();

Hubs\UploadHub.cs (1)

65var output = Channel.CreateUnbounded<string>();

ObservableExtensions.cs (1)

26var channel = maxBufferSize != null ? Channel.CreateBounded<T>(maxBufferSize.Value) : Channel.CreateUnbounded<T>();

ProducerConsumer.cs (1)

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

Program.cs (1)

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

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

55private readonly Channel<WriteQueueEntry> _writeChannel;

System\Net\Quic\QuicConnection.cs (1)

149private readonly Channel<QuicStream> _acceptQueue = Channel.CreateUnbounded<QuicStream>(new UnboundedChannelOptions()

System\Net\Quic\QuicListener.cs (1)

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

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (4)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new() 353static (obj, cancellationToken) => ((Channel<TItem>)obj!).Writer.TryComplete(new OperationCanceledException(cancellationToken)),

Program.cs (1)

119private readonly Channel<string> _channel;

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (3)

59var channel = Channel.CreateBounded<T>(1024); 95public static void CompletesChannel<T>(this Task task, Channel<T> channel) 100static (task, channel) => ((Channel<T>)channel!).Writer.Complete(task.Exception),

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (3)

270var channel = Channel.CreateUnbounded<TItem>(); 324/// cref="Channel{T}"/>, which will then then manage the rules and behaviors around the routines. Importantly, the 343var channel = Channel.CreateUnbounded<TItem>(new()