UnboundedChannelOptions

28 instantiations of UnboundedChannelOptions

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)

608new UnboundedChannelOptions { AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true }); 653new UnboundedChannelOptions { AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true }); 699new UnboundedChannelOptions { AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true });

Aspire.Hosting (5)

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

693var channel = Channel.CreateUnbounded<ResourceLogLine>(new UnboundedChannelOptions

Dashboard\ResourcePublisher.cs (1)

50new UnboundedChannelOptions { AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true });

Dcp\DcpExecutor.cs (1)

98new UnboundedChannelOptions { SingleReader = true });

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)

26private static readonly UnboundedChannelOptions s_outputChannelOptions = new()

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)

212new UnboundedChannelOptions { SingleWriter = true });

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)

118private static readonly UnboundedChannelOptions s_channelOptions = new UnboundedChannelOptions() { SingleReader = true };

System.Net.Quic (1)

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

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

3 references to UnboundedChannelOptions

Microsoft.DotNet.HotReload.Watch (1)

Aspire\AspireServiceFactory.cs (1)

26private static readonly UnboundedChannelOptions s_outputChannelOptions = new()

System.Net.Http (1)

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

118private static readonly UnboundedChannelOptions s_channelOptions = new UnboundedChannelOptions() { SingleReader = true };

System.Threading.Channels (1)

System\Threading\Channels\Channel.cs (1)

19public static Channel<T> CreateUnbounded<T>(UnboundedChannelOptions options)