37 references to CreateUnbounded
aspire (4)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
68var connectionChanges = Channel.CreateUnbounded<bool>(new UnboundedChannelOptions
Commands\PsCommand.cs (1)
186var updates = Channel.CreateUnbounded<PsFollowUpdate>(new UnboundedChannelOptions
Interaction\ExtensionInteractionService.cs (1)
55_extensionTaskChannel = Channel.CreateUnbounded<Func<Task>>(new UnboundedChannelOptions
Projects\ProjectLocator.cs (1)
194var channel = Channel.CreateUnbounded<AppHostProjectCandidate>(new UnboundedChannelOptions
Aspire.Dashboard (6)
Components\Pages\ConsoleLogs.razor.cs (1)
141private readonly Channel<LogEntryToWrite> _logEntryChannel = Channel.CreateUnbounded<LogEntryToWrite>(new UnboundedChannelOptions
ServiceClient\DashboardClient.cs (3)
855var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 900var channel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>( 952var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(
ServiceClient\SqliteResourceRepository.cs (2)
67var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>(new UnboundedChannelOptions 129channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(new UnboundedChannelOptions
Aspire.Hosting (5)
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
1632var channel = Channel.CreateUnbounded<ResourceLogLine>(new UnboundedChannelOptions
Dashboard\ResourcePublisher.cs (1)
49var channel = Channel.CreateUnbounded<ResourceSnapshotChange>(
Dcp\DcpResourceWatcher.cs (1)
57private readonly Channel<LogInformationEntry> _logInformationChannel = Channel.CreateUnbounded<LogInformationEntry>(
Dcp\ResourceLogSource.cs (1)
48var channel = Channel.CreateUnbounded<ResourceLogEntry>(new UnboundedChannelOptions
Devcontainers\DevcontainerSettingsWriter.cs (1)
27private readonly Channel<PortForwardEntry> _portUpdates = Channel.CreateUnbounded<PortForwardEntry>(new UnboundedChannelOptions
Aspire.Hosting.Azure (1)
AzureProvisioningController.cs (1)
128private readonly Channel<QueuedOperation> _operationChannel = Channel.CreateUnbounded<QueuedOperation>(new UnboundedChannelOptions
dotnet (1)
Commands\Test\MTP\TestApplicationActionQueue.cs (1)
33_channel = Channel.CreateUnbounded<ParallelizableTestModuleGroupWithSequentialInnerModules>(new UnboundedChannelOptions { SingleReader = false, SingleWriter = false });
dotnet-aot (1)
src\sdk\src\Cli\dotnet\Commands\Test\MTP\TestApplicationActionQueue.cs (1)
33_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.AspNetCore.Server.Kestrel.Transport.DirectTls (1)
Connection\DirectTlsConnectionListener.cs (1)
87_readyConnections = Channel.CreateUnbounded<DirectTlsConnection>(new UnboundedChannelOptions
Microsoft.AspNetCore.SignalR.Client.Core (1)
HubConnection.cs (1)
1919var invocationMessageChannel = Channel.CreateUnbounded<InvocationMessage>(_receiveLoopOptions);
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)
1038_eventQueue = Channel.CreateUnbounded<WatcherEvent>(new UnboundedChannelOptions() { AllowSynchronousContinuations = false, SingleReader = true });
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
153_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()