BoundedChannelOptions

5 instantiations of BoundedChannelOptions

Aspire.Confluent.Kafka (1)

MetricsChannel.cs (1)

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

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 });

2 references to BoundedChannelOptions

System.Threading.Channels (2)

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

55public static Channel<T> CreateBounded<T>(BoundedChannelOptions options) 65public static Channel<T> CreateBounded<T>(BoundedChannelOptions options, Action<T>? itemDropped)