new

17 instantiations of new

Aspire.Dashboard (2)

ResourceService\DashboardClient.cs (2)

438new UnboundedChannelOptions { AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true }); 487new UnboundedChannelOptions { AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true });

Aspire.Hosting (3)

Dashboard\ResourcePublisher.cs (1)

50new UnboundedChannelOptions { AllowSynchronousContinuations = false, SingleReader = true, SingleWriter = true });

Dcp\ApplicationExecutor.cs (1)

118new UnboundedChannelOptions { SingleReader = true });

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)

65private static readonly UnboundedChannelOptions _receiveLoopOptions = new UnboundedChannelOptions

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)

212new UnboundedChannelOptions { SingleWriter = true });

System.Net.Http (1)

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)

117private static readonly UnboundedChannelOptions s_channelOptions = new UnboundedChannelOptions() { SingleReader = true };

System.Net.Quic (1)

System\Net\Quic\QuicConnection.cs (1)

149private readonly Channel<QuicStream> _acceptQueue = Channel.CreateUnbounded<QuicStream>(new UnboundedChannelOptions()

3 references to new

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

HubConnection.cs (1)

65private static readonly UnboundedChannelOptions _receiveLoopOptions = new UnboundedChannelOptions

System.Net.Http (1)

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (1)

117private static readonly UnboundedChannelOptions s_channelOptions = new UnboundedChannelOptions() { SingleReader = true };

System.Threading.Channels (1)

System\Threading\Channels\Channel.cs (1)

18public static Channel<T> CreateUnbounded<T>(UnboundedChannelOptions options)