17 references to CreateUnbounded
Aspire.Dashboard (2)
ResourceService\DashboardClient.cs (2)
435var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceViewModelChange>>( 484var channel = Channel.CreateUnbounded<IReadOnlyList<ResourceLogLine>>(
Aspire.Hosting (3)
Dashboard\ResourcePublisher.cs (1)
49var channel = Channel.CreateUnbounded<ResourceSnapshotChange>(
Dcp\ApplicationExecutor.cs (1)
117private readonly Channel<LogInformationEntry> _logInformationChannel = Channel.CreateUnbounded<LogInformationEntry>(
Dcp\ResourceLogSource.cs (1)
28var channel = Channel.CreateUnbounded<LogEntry>(new UnboundedChannelOptions
InMemory.FunctionalTests (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)
991public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.CreateUnbounded<ConnectionContext>(new UnboundedChannelOptions 997public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)
991public readonly Channel<ConnectionContext> ToServerAcceptQueue = Channel.CreateUnbounded<ConnectionContext>(new UnboundedChannelOptions 997public readonly Channel<Http3ControlStream> ToClientAcceptQueue = Channel.CreateUnbounded<Http3ControlStream>(new UnboundedChannelOptions
Microsoft.AspNetCore.SignalR.Client.Core (1)
HubConnection.cs (1)
1601var invocationMessageChannel = Channel.CreateUnbounded<InvocationMessage>(_receiveLoopOptions);
Microsoft.CodeAnalysis.CodeStyle (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
283var channel = Channel.CreateUnbounded<TItem>(new()
Microsoft.CodeAnalysis.Workspaces (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\ProducerConsumer.cs (1)
283var 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>(
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)
149private readonly Channel<QuicStream> _acceptQueue = Channel.CreateUnbounded<QuicStream>(new UnboundedChannelOptions()