28 references to CreateUnbounded
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
43_extensionTaskChannel = Channel.CreateUnbounded<Func<Task>>(new UnboundedChannelOptions
Aspire.Dashboard (4)
Components\Pages\ConsoleLogs.razor.cs (1)
146private readonly Channel<LogEntryToWrite> _logEntryChannel = Channel.CreateUnbounded<LogEntryToWrite>(new UnboundedChannelOptions
ServiceClient\DashboardClient.cs (3)
607var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 652var channel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>( 698var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(
Aspire.Hosting (5)
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
693var channel = Channel.CreateUnbounded<ResourceLogLine>(new UnboundedChannelOptions
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
dotnet (1)
Commands\Test\MTP\TestApplicationActionQueue.cs (1)
22_channel = Channel.CreateUnbounded<ParallelizableTestModuleGroupWithSequentialInnerModules>(new UnboundedChannelOptions { SingleReader = false, SingleWriter = false });
GenerateDocumentationAndConfigFiles (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
326var channel = Channel.CreateUnbounded<TItem>(new()
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 (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
326var channel = Channel.CreateUnbounded<TItem>(new()
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
326var channel = Channel.CreateUnbounded<TItem>(new()
Microsoft.CodeAnalysis.CodeStyle (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
326var channel = Channel.CreateUnbounded<TItem>(new()
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
326var channel = Channel.CreateUnbounded<TItem>(new()
Microsoft.CodeAnalysis.Workspaces (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
326var channel = Channel.CreateUnbounded<TItem>(new()
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.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 (1)
src\roslyn\src\Dependencies\Threading\ProducerConsumer.cs (1)
326var channel = Channel.CreateUnbounded<TItem>(new()
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 (1)
System\Net\Quic\QuicConnection.cs (1)
150private readonly Channel<QuicStream> _acceptQueue = Channel.CreateUnbounded<QuicStream>(new UnboundedChannelOptions()