34 references to CreateUnbounded
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
42
_extensionTaskChannel = Channel.
CreateUnbounded
<Func<Task>>(new UnboundedChannelOptions
Aspire.Dashboard (4)
Components\Pages\ConsoleLogs.razor.cs (1)
144
private readonly Channel<LogEntryToWrite> _logEntryChannel = Channel.
CreateUnbounded
<LogEntryToWrite>(new UnboundedChannelOptions
ServiceClient\DashboardClient.cs (3)
587
var channel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>(
632
var channel = Channel.
CreateUnbounded
<WatchInteractionsResponseUpdate>(
678
var channel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>(
Aspire.Hosting (4)
Dashboard\ResourcePublisher.cs (1)
49
var channel = Channel.
CreateUnbounded
<ResourceSnapshotChange>(
Dcp\DcpExecutor.cs (1)
90
private readonly Channel<LogInformationEntry> _logInformationChannel = Channel.
CreateUnbounded
<LogInformationEntry>(
Dcp\ResourceLogSource.cs (1)
28
var channel = Channel.
CreateUnbounded
<LogEntry>(new UnboundedChannelOptions
Devcontainers\DevcontainerSettingsWriter.cs (1)
27
private 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 });
dotnet-watch (1)
Aspire\AspireServiceFactory.cs (1)
114
var outputChannel = Channel.
CreateUnbounded
<OutputLine>(s_outputChannelOptions);
InMemory.FunctionalTests (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)
990
public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.
CreateUnbounded
<ConnectionContext>(new UnboundedChannelOptions
996
public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.
CreateUnbounded
<Http3ControlStream>(new UnboundedChannelOptions
Metrics (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Metrics.Legacy (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)
990
public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.
CreateUnbounded
<ConnectionContext>(new UnboundedChannelOptions
996
public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.
CreateUnbounded
<Http3ControlStream>(new UnboundedChannelOptions
Microsoft.AspNetCore.SignalR.Client.Core (1)
HubConnection.cs (1)
1611
var invocationMessageChannel = Channel.
CreateUnbounded
<InvocationMessage>(_receiveLoopOptions);
Microsoft.CodeAnalysis.Analyzers (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Microsoft.CodeAnalysis.BannedApiAnalyzers (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Microsoft.CodeAnalysis.CodeStyle (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Microsoft.CodeAnalysis.PublicApiAnalyzers (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Microsoft.CodeAnalysis.Threading.Package (1)
ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
Microsoft.CodeAnalysis.Workspaces (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(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)
211
_paramChannel = Channel.
CreateUnbounded
<ParameterSetWithId>(
Roslyn.Diagnostics.Analyzers (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()
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)
150
private readonly Channel<QuicStream> _acceptQueue = Channel.
CreateUnbounded
<QuicStream>(new UnboundedChannelOptions()
Text.Analyzers (1)
src\Dependencies\Threading\ProducerConsumer.cs (1)
326
var channel = Channel.
CreateUnbounded
<TItem>(new()