CreateUnbounded

30 references to CreateUnbounded

aspire (1)

Interaction\ExtensionInteractionService.cs (1)

36_extensionTaskChannel = Channel.CreateUnbounded<Func<Task>>(new UnboundedChannelOptions

Aspire.Dashboard (3)

ServiceClient\DashboardClient.cs (3)

575var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 620var channel = Channel.CreateUnbounded<WatchInteractionsResponseUpdate>( 666var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(

Aspire.Hosting (3)

Dashboard\ResourcePublisher.cs (1)

49var channel = Channel.CreateUnbounded<ResourceSnapshotChange>(

Dcp\DcpExecutor.cs (1)

90private readonly Channel<LogInformationEntry> _logInformationChannel = Channel.CreateUnbounded<LogInformationEntry>(

Dcp\ResourceLogSource.cs (1)

28var channel = Channel.CreateUnbounded<LogEntry>(new UnboundedChannelOptions

GenerateDocumentationAndConfigFiles (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

InMemory.FunctionalTests (2)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

990public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.CreateUnbounded<ConnectionContext>(new UnboundedChannelOptions 996public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions

Metrics (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Metrics.Legacy (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

Microsoft.AspNetCore.SignalR.Client.Core (1)

HubConnection.cs (1)

1611var invocationMessageChannel = Channel.CreateUnbounded<InvocationMessage>(_receiveLoopOptions);

Microsoft.CodeAnalysis.Analyzers (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Microsoft.CodeAnalysis.AnalyzerUtilities (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Microsoft.CodeAnalysis.BannedApiAnalyzers (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Microsoft.CodeAnalysis.CodeStyle (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Microsoft.CodeAnalysis.PublicApiAnalyzers (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Microsoft.CodeAnalysis.ResxSourceGenerator (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Microsoft.CodeAnalysis.Threading.Package (1)

ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Microsoft.CodeAnalysis.Workspaces (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var 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)

326var channel = Channel.CreateUnbounded<TItem>(new()

Test.Utilities (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()

Text.Analyzers (1)

src\Dependencies\Threading\ProducerConsumer.cs (1)

326var channel = Channel.CreateUnbounded<TItem>(new()