31 instantiations of new
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
28
_extensionTaskChannel = Channel.CreateUnbounded<Func<Task>>(new
UnboundedChannelOptions
Aspire.Dashboard (3)
ServiceClient\DashboardClient.cs (3)
566
new
UnboundedChannelOptions
{ AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true });
611
new
UnboundedChannelOptions
{ AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true });
657
new
UnboundedChannelOptions
{ AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true });
Aspire.Hosting (3)
Dashboard\ResourcePublisher.cs (1)
50
new
UnboundedChannelOptions
{ AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true });
Dcp\DcpExecutor.cs (1)
74
new
UnboundedChannelOptions
{ SingleReader = true });
Dcp\ResourceLogSource.cs (1)
28
var channel = Channel.CreateUnbounded<LogEntry>(new
UnboundedChannelOptions
GenerateDocumentationAndConfigFiles (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
Metrics.Legacy (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
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)
65
private static readonly UnboundedChannelOptions _receiveLoopOptions = new
UnboundedChannelOptions
Microsoft.CodeAnalysis.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
Microsoft.CodeAnalysis.AnalyzerUtilities (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
Microsoft.CodeAnalysis.BannedApiAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
Microsoft.CodeAnalysis.CodeStyle (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
Microsoft.CodeAnalysis.PublicApiAnalyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
Microsoft.CodeAnalysis.ResxSourceGenerator (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
Microsoft.CodeAnalysis.Workspaces (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
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)
212
new
UnboundedChannelOptions
{ SingleWriter = true });
Roslyn.Diagnostics.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
117
private static readonly UnboundedChannelOptions s_channelOptions = new
UnboundedChannelOptions
() { SingleReader = true };
System.Net.Quic (1)
System\Net\Quic\QuicConnection.cs (1)
149
private readonly Channel<QuicStream> _acceptQueue = Channel.CreateUnbounded<QuicStream>(new
UnboundedChannelOptions
()
Test.Utilities (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
Text.Analyzers (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
343
var channel = Channel.CreateUnbounded<TItem>(
new
()
3 references to new
Microsoft.AspNetCore.SignalR.Client.Core (1)
HubConnection.cs (1)
65
private static readonly
UnboundedChannelOptions
_receiveLoopOptions = new UnboundedChannelOptions
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)
117
private static readonly
UnboundedChannelOptions
s_channelOptions = new UnboundedChannelOptions() { SingleReader = true };
System.Threading.Channels (1)
System\Threading\Channels\Channel.cs (1)
19
public static Channel<T> CreateUnbounded<T>(
UnboundedChannelOptions
options)