162 references to Channel
aspire (2)
Diagnostics\FileLoggerProvider.cs (1)
94Channel.CreateBounded<string>(new BoundedChannelOptions(MaxQueuedMessages)
Interaction\ExtensionInteractionService.cs (1)
43_extensionTaskChannel = Channel.CreateUnbounded<Func<Task>>(new UnboundedChannelOptions
Aspire.Cli.Tests (2)
Commands\AgentMcpCommandTests.cs (2)
380var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>(); 475var notificationChannel = Channel.CreateUnbounded<JsonRpcNotification>();
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 (8)
Components\Pages\ConsoleLogs.razor.cs (1)
146private readonly Channel<LogEntryToWrite> _logEntryChannel = Channel.CreateUnbounded<LogEntryToWrite>(new UnboundedChannelOptions
Otlp\Storage\TelemetryRepository.Watchers.cs (2)
40var channel = Channel.CreateBounded<OtlpSpan>(new BoundedChannelOptions(1000) 133var channel = Channel.CreateBounded<OtlpLogEntry>(new BoundedChannelOptions(1000)
ServiceClient\DashboardClient.cs (4)
51private readonly Channel<WatchInteractionsRequestUpdate> _incomingInteractionChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 607var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 652var channel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>( 698var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(
Telemetry\DashboardTelemetrySender.cs (1)
38_channel = Channel.CreateBounded<(OperationContext, Func<HttpClient, Func<OperationContextProperty, object>, Task>)>(channelOptions);
Aspire.Dashboard.Components.Tests (57)
Interactions\InteractionsProviderTests.cs (13)
60var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 87var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 134var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 185var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 186var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 244var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 245var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 307var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 308var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 380var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 381var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>(); 458var interactionsChannel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>(); 459var sendInteractionUpdatesChannel = Channel.CreateUnbounded<WatchInteractionsRequestUpdate>();
Pages\ConsoleLogsTests.cs (28)
39var subscribedResourceNamesChannel = Channel.CreateUnbounded<string>(); 40var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 41var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 89var subscribedResourceNamesChannel = Channel.CreateUnbounded<string>(); 90var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 91var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 150consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 178var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 179var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 279var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 280var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 331var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 332var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 379var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 380var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 428var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 429var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 477var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 478var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 534var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 535var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 595var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 596var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 659var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 660var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 661var resourceCommandChannel = Channel.CreateUnbounded<ResourceCommandResponseViewModel>(); 718var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(); 719var resourceChannel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>();
Pages\ResourcesTests.cs (14)
38var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 137var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 189var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 225resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 320var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(); 402var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 430var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 460var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 492var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 525var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 566var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 610var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 652var dashboardClient = new TestDashboardClient(isEnabled: true, initialResources: initialResources, resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>); 691resourceChannelProvider: Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>,
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>();
Aspire.Dashboard.Tests (14)
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)
98var 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>();
Aspire.Hosting (12)
ApplicationModel\ResourceLoggerService.cs (3)
225var channel = Channel.CreateUnbounded<LogSubscriber>(); 314var channel = Channel.CreateUnbounded<IReadOnlyList<LogLine>>(); 436var channel = Channel.CreateUnbounded<LogEntry>();
ApplicationModel\ResourceNotificationService.cs (1)
577var channel = Channel.CreateUnbounded<ResourceEvent>();
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
693var channel = Channel.CreateUnbounded<ResourceLogLine>(new UnboundedChannelOptions
Backchannel\BackchannelLoggerProvider.cs (1)
23var channel = Channel.CreateUnbounded<BackchannelLogEntry>();
Dashboard\ResourcePublisher.cs (1)
49var channel = Channel.CreateUnbounded<ResourceSnapshotChange>(
Dcp\DcpExecutor.cs (1)
97private 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)
486internal Channel<PublishingActivity> ActivityItemUpdated { get; } = Channel.CreateUnbounded<PublishingActivity>();
Aspire.Hosting.Azure.Tests (1)
tests\Shared\TestInteractionService.cs (1)
14public Channel<InteractionData> Interactions { get; } = Channel.CreateUnbounded<InteractionData>();
Aspire.Hosting.Tests (20)
Cli\CliOrphanDetectorTests.cs (2)
116var processRunningChannel = Channel.CreateUnbounded<int>(); 186var processRunningChannel = Channel.CreateUnbounded<int>();
Dashboard\DashboardLifecycleHookTests.cs (1)
40var logChannel = Channel.CreateUnbounded<WriteContext>();
Dashboard\DashboardServiceTests.cs (1)
36var getConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>();
Dcp\DcpExecutorTests.cs (2)
76var channel = Channel.CreateUnbounded<string>(); 608var logStreamPipesChannel = Channel.CreateUnbounded<(string Type, Pipe Pipe)>();
Dcp\TestKubernetesService.cs (1)
134var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>();
DistributedApplicationTests.cs (1)
1065var beforeResourceStartedEvents = Channel.CreateUnbounded<BeforeResourceStartedEvent>();
Health\ResourceHealthCheckServiceTests.cs (2)
148var channel = Channel.CreateUnbounded<ResourceReadyEvent>(); 293var channel = Channel.CreateUnbounded<DateTimeOffset>();
InteractionServiceTests.cs (3)
125var updates = Channel.CreateUnbounded<Interaction>(); 816var updates = Channel.CreateUnbounded<Interaction>(); 869var updates = Channel.CreateUnbounded<Interaction>();
ResourceCommandServiceTests.cs (2)
80var commandResourcesChannel = Channel.CreateUnbounded<string>(); 117var commandResourcesChannel = Channel.CreateUnbounded<string>();
ResourceLoggerServiceTests.cs (2)
262var consoleLogsChannel0 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 266var 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>();
dotnet (1)
Commands\Test\MTP\TestApplicationActionQueue.cs (1)
22_channel = Channel.CreateUnbounded<ParallelizableTestModuleGroupWithSequentialInnerModules>(new UnboundedChannelOptions { SingleReader = false, SingleWriter = false });
dotnet-watch (1)
UI\SpectreBuildParametersSelectionPrompt.cs (1)
115private readonly Channel<ConsoleKeyInfo> _channel = Channel.CreateUnbounded<ConsoleKeyInfo>();
GenerateDocumentationAndConfigFiles (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
50var channel = Channel.CreateBounded<T>(1024);
Microsoft.AspNetCore.Server.Kestrel.Core (2)
Internal\Http2\Http2FrameWriter.cs (1)
153_channel = Channel.CreateBounded<Http2OutputProducer>(new BoundedChannelOptions(maxStreamsPerConnection)
Internal\WebTransport\WebTransportSession.cs (1)
52_pendingStreams = Channel.CreateUnbounded<WebTransportStream>();
Microsoft.AspNetCore.SignalR.Core (3)
Internal\ChannelBasedSemaphore.cs (1)
17_channel = Channel.CreateBounded<int>(maxCapacity);
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
32private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
StreamTracker.cs (1)
112_channel = Channel.CreateBounded<T?>(streamBufferCapacity);
Microsoft.Build.Tasks.Core (2)
AssemblyDependency\Node\RarNodeBuildEngine.cs (2)
57_eventChannel = Channel.CreateUnbounded<BuildEventArgs>(new UnboundedChannelOptions 62_eventCountChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions
Microsoft.CodeAnalysis.Analyzers (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
50var channel = Channel.CreateBounded<T>(1024);
Microsoft.CodeAnalysis.AnalyzerUtilities (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
50var channel = Channel.CreateBounded<T>(1024);
Microsoft.CodeAnalysis.CodeStyle (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
50var channel = Channel.CreateBounded<T>(1024);
Microsoft.CodeAnalysis.ResxSourceGenerator (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
50var channel = Channel.CreateBounded<T>(1024);
Microsoft.CodeAnalysis.Workspaces (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
50var channel = Channel.CreateBounded<T>(1024);
Microsoft.DotNet.HotReload.Utils.Generator (1)
Util\FSWGen.cs (1)
19_channel = Channel.CreateUnbounded<System.IO.FileSystemEventArgs> (new UnboundedChannelOptions { SingleReader = true, AllowSynchronousContinuations = true});
Microsoft.DotNet.HotReload.Watch (1)
Aspire\AspireServiceFactory.cs (1)
129var outputChannel = Channel.CreateUnbounded<OutputLine>(s_outputChannelOptions);
Microsoft.Extensions.AI (1)
ChatCompletion\AnonymousDelegatingChatClient.cs (1)
134var updates = Channel.CreateBounded<ChatResponseUpdate>(1);
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
266var channel = Channel.CreateUnbounded<ServiceEndpointResolverResult>();
Microsoft.ML.Data (2)
Transforms\RowShufflingTransformer.cs (2)
544_toConsumeChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions { SingleWriter = true }); 545_toProduceChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions { SingleWriter = true });
Microsoft.ML.Sweeper (1)
AsyncSweeper.cs (1)
211_paramChannel = Channel.CreateUnbounded<ParameterSetWithId>(
Roslyn.Diagnostics.Analyzers (3)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (2)
253var channel = Channel.CreateUnbounded<TItem>(); 326var channel = Channel.CreateUnbounded<TItem>(new()
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
50var channel = Channel.CreateBounded<T>(1024);
Stress.ApiService (2)
ProducerConsumer.cs (1)
20private readonly Channel<Data> _channel = Channel.CreateUnbounded<Data>();
Program.cs (1)
238var 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)
1029_eventQueue = Channel.CreateUnbounded<WatcherEvent>(new UnboundedChannelOptions() { AllowSynchronousContinuations = false, SingleReader = true });
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
150_writeChannel = Channel.CreateUnbounded<WriteQueueEntry>(s_channelOptions);
System.Net.Quic (2)
System\Net\Quic\QuicConnection.cs (1)
150private readonly Channel<QuicStream> _acceptQueue = Channel.CreateUnbounded<QuicStream>(new UnboundedChannelOptions()
System\Net\Quic\QuicListener.cs (1)
143_acceptQueue = Channel.CreateUnbounded<object>();