31 references to CreateUnbounded
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
28
_extensionTaskChannel = Channel.
CreateUnbounded
<Func<Task>>(new UnboundedChannelOptions
Aspire.Dashboard (3)
ServiceClient\DashboardClient.cs (3)
565
var channel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceViewModelChange>>(
610
var channel = Channel.
CreateUnbounded
<WatchInteractionsResponseUpdate>(
656
var channel = Channel.
CreateUnbounded
<IReadOnlyList<ResourceLogLine>>(
Aspire.Hosting (3)
Dashboard\ResourcePublisher.cs (1)
49
var channel = Channel.
CreateUnbounded
<ResourceSnapshotChange>(
Dcp\DcpExecutor.cs (1)
73
private readonly Channel<LogInformationEntry> _logInformationChannel = Channel.
CreateUnbounded
<LogInformationEntry>(
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)
1611
var invocationMessageChannel = Channel.
CreateUnbounded
<InvocationMessage>(_receiveLoopOptions);
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)
211
_paramChannel = Channel.
CreateUnbounded
<ParameterSetWithId>(
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)
149
_writeChannel = Channel.
CreateUnbounded
<WriteQueueEntry>(s_channelOptions);
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()