Channel

Interaction\ExtensionInteractionService.cs (1)

42_extensionTaskChannel = Channel.CreateUnbounded<Func<Task>>(new UnboundedChannelOptions

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)

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

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

ServiceClient\DashboardClient.cs (4)

51private readonly Channel<WatchInteractionsRequestUpdate> _incomingInteractionChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 597var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 642var channel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>( 688var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(

Telemetry\DashboardTelemetrySender.cs (1)

38_channel = Channel.CreateBounded<(OperationContext, Func<HttpClient, Func<OperationContextProperty, object>, Task>)>(channelOptions);

Interactions\InteractionsProviderTests.cs (13)

Pages\ConsoleLogsTests.cs (26)

Pages\ResourcesTests.cs (14)

Shared\ResourceSetupHelpers.cs (1)

63context.Services.AddSingleton<IDashboardClient>(dashboardClient ?? new TestDashboardClient(isEnabled: true, initialResources: [], resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>));

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>> ResourceInformationCallsChannel { get; } = Channel.CreateUnbounded<ReceivedCallInfo<ApplicationInformationRequest>>();

Mcp\AspireResourceMcpToolsTests.cs (1)

133var logsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>();

Model\AIAssistant\AIContextProviderTests.cs (1)

81var changeChannel = Channel.CreateUnbounded<AIContext?>();

Model\AIAssistant\AssistantChatDataContextTests.cs (1)

97var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>();

ResourceOutgoingPeerResolverTests.cs (2)

131var sourceChannel = Channel.CreateUnbounded<ResourceViewModelChange>(); 132var 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\ResourceLoggerService.cs (3)

225var channel = Channel.CreateUnbounded<LogSubscriber>(); 314var channel = Channel.CreateUnbounded<IReadOnlyList<LogLine>>(); 436var channel = Channel.CreateUnbounded<LogEntry>();

ApplicationModel\ResourceNotificationService.cs (1)

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

Backchannel\AuxiliaryBackchannelRpcTarget.cs (2)

405var channel = System.Threading.Channels.Channel.CreateUnbounded<ResourceLogLine>(); 494var channel = System.Threading.Channels.Channel.CreateUnbounded<ResourceLogLine>();

Backchannel\BackchannelLoggerProvider.cs (1)

12private readonly Channel<BackchannelLogEntry> _channel = Channel.CreateUnbounded<BackchannelLogEntry>();

Dashboard\ResourcePublisher.cs (1)

49var channel = Channel.CreateUnbounded<ResourceSnapshotChange>(

Dcp\DcpExecutor.cs (1)

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

Dcp\ResourceLogSource.cs (1)

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

Devcontainers\DevcontainerSettingsWriter.cs (1)

27private readonly Channel<PortForwardEntry> _portUpdates = Channel.CreateUnbounded<PortForwardEntry>(new UnboundedChannelOptions

InteractionService.cs (1)

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

Pipelines\PipelineActivityReporter.cs (1)

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

tests\Shared\TestInteractionService.cs (1)

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

Cli\CliOrphanDetectorTests.cs (2)

117var processRunningChannel = Channel.CreateUnbounded<int>(); 188var processRunningChannel = Channel.CreateUnbounded<int>();

Dashboard\DashboardLifecycleHookTests.cs (1)

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

Dashboard\DashboardServiceTests.cs (1)

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

Dcp\DcpExecutorTests.cs (2)

75var channel = Channel.CreateUnbounded<string>(); 607var logStreamPipesChannel = Channel.CreateUnbounded<(string Type, Pipe Pipe)>();

Dcp\TestKubernetesService.cs (1)

134var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>();

DistributedApplicationTests.cs (1)

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

Health\ResourceHealthCheckServiceTests.cs (2)

147var channel = Channel.CreateUnbounded<ResourceReadyEvent>(); 292var channel = Channel.CreateUnbounded<DateTimeOffset>();

InteractionServiceTests.cs (3)

124var updates = Channel.CreateUnbounded<Interaction>(); 815var updates = Channel.CreateUnbounded<Interaction>(); 868var updates = Channel.CreateUnbounded<Interaction>();

ResourceCommandServiceTests.cs (2)

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

ResourceLoggerServiceTests.cs (2)

261var consoleLogsChannel0 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 265var consoleLogsChannel1 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>();

tests\Shared\TestInteractionService.cs (1)

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

Utils\Grpc\TestAsyncStreamReader.cs (1)

18_channel = Channel.CreateUnbounded<T>();

Utils\Grpc\TestServerStreamWriter.cs (1)

18_channel = Channel.CreateUnbounded<T>();

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\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

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

45_serverReceivedSettings = Channel.CreateUnbounded<KeyValuePair<Http3SettingType, long>>(); 1008public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.CreateUnbounded<ConnectionContext>(new UnboundedChannelOptions 1014public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions

TestTransport\InMemoryTransportFactory.cs (1)

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

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

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

33_counters[item] = Channel.CreateUnbounded<double>();

TestWebSocketConnectionFeature.cs (2)

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

Internal\Http2\Http2FrameWriter.cs (1)

153_channel = Channel.CreateBounded<Http2OutputProducer>(new BoundedChannelOptions(maxStreamsPerConnection)

Internal\WebTransport\WebTransportSession.cs (1)

52_pendingStreams = Channel.CreateUnbounded<WebTransportStream>();

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

45_serverReceivedSettings = Channel.CreateUnbounded<KeyValuePair<Http3SettingType, long>>(); 1008public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.CreateUnbounded<ConnectionContext>(new UnboundedChannelOptions 1014public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions

Internal\NamedPipeConnectionListener.cs (1)

52_acceptedQueue = Channel.CreateBounded<ConnectionContext>(new BoundedChannelOptions(capacity: 1));

HubConnection.cs (1)

1611var invocationMessageChannel = Channel.CreateUnbounded<InvocationMessage>(_receiveLoopOptions);

HubConnectionExtensions.StreamAsChannelAsync.cs (1)

277var outputChannel = Channel.CreateUnbounded<TResult>();

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)

17_channel = Channel.CreateBounded<int>(maxCapacity);

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

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

StreamTracker.cs (1)

112_channel = Channel.CreateBounded<T?>(streamBufferCapacity);

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

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\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

ChatCompletion\AnonymousDelegatingChatClient.cs (1)

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

ServiceEndpointResolverTests.cs (1)

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

Transforms\RowShufflingTransformer.cs (2)

544_toConsumeChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions { SingleWriter = true }); 545_toProduceChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions { SingleWriter = true });

AsyncSweeper.cs (1)

211_paramChannel = Channel.CreateUnbounded<ParameterSetWithId>(

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

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

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)

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

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

1029_eventQueue = Channel.CreateUnbounded<WatcherEvent>(new UnboundedChannelOptions() { AllowSynchronousContinuations = false, SingleReader = true });

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

150_writeChannel = Channel.CreateUnbounded<WriteQueueEntry>(s_channelOptions);

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

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

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

143_acceptQueue = Channel.CreateUnbounded<object>();

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);

Program.cs (1)

117_channel = Channel.CreateUnbounded<string>();

src\Dependencies\Threading\ProducerConsumer.cs (2)

253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()

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

50var channel = Channel.CreateBounded<T>(1024);