7 references to BoundedChannelOptions
aspire (1)
Diagnostics\FileLoggerProvider.cs (1)
94
Channel.CreateBounded<string>(new
BoundedChannelOptions
(MaxQueuedMessages)
Aspire.Confluent.Kafka (1)
MetricsChannel.cs (1)
17
private readonly Channel<string> _channel = Channel.CreateBounded<string>(new
BoundedChannelOptions
(10_000)
Aspire.Dashboard (3)
Otlp\Storage\TelemetryRepository.Watchers.cs (2)
40
var channel = Channel.CreateBounded<OtlpSpan>(new
BoundedChannelOptions
(1000)
133
var channel = Channel.CreateBounded<OtlpLogEntry>(new
BoundedChannelOptions
(1000)
Telemetry\DashboardTelemetrySender.cs (1)
33
var 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.SignalR.Core (1)
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
32
private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new
BoundedChannelOptions
(1) { FullMode = BoundedChannelFullMode.DropOldest });