BoundedChannelOptions

6 instantiations of BoundedChannelOptions

Aspire.Confluent.Kafka (1)

MetricsChannel.cs (1)

17private readonly Channel<string> _channel = Channel.CreateBounded<string>(new BoundedChannelOptions(10_000)

Aspire.Dashboard (1)

Telemetry\DashboardTelemetrySender.cs (1)

33var channelOptions = new BoundedChannelOptions(1000)

Microsoft.AspNetCore.Server.Kestrel.Core (1)

Internal\Http2\Http2FrameWriter.cs (1)

153_channel = Channel.CreateBounded<Http2OutputProducer>(new BoundedChannelOptions(maxStreamsPerConnection)

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)

Internal\NamedPipeConnectionListener.cs (1)

52_acceptedQueue = Channel.CreateBounded<ConnectionContext>(new BoundedChannelOptions(capacity: 1));

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

src\SignalR\common\Shared\MessageBuffer.cs (1)

32private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });

Microsoft.AspNetCore.SignalR.Core (1)

src\SignalR\common\Shared\MessageBuffer.cs (1)

32private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });

3 references to BoundedChannelOptions

Aspire.Dashboard (1)

Telemetry\DashboardTelemetrySender.cs (1)

33var channelOptions = new BoundedChannelOptions(1000)

System.Threading.Channels (2)

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

52public static Channel<T> CreateBounded<T>(BoundedChannelOptions options) 62public static Channel<T> CreateBounded<T>(BoundedChannelOptions options, Action<T>? itemDropped)