5 references to CreateBounded
Aspire.Confluent.Kafka (1)
MetricsChannel.cs (1)
17
private 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)
32
private 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)
32
private readonly Channel<long> _waitForAck = Channel.
CreateBounded
<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });