12 references to BoundedChannelOptions
aspire (2)
Backchannel\ResourceSnapshotWatcher.cs (1)
42new BoundedChannelOptions(1)
Diagnostics\FileLoggerProvider.cs (1)
94Channel.CreateBounded<string>(new BoundedChannelOptions(MaxQueuedMessages)
Aspire.Confluent.Kafka (1)
MetricsChannel.cs (1)
17private readonly Channel<string> _channel = Channel.CreateBounded<string>(new BoundedChannelOptions(10_000)
Aspire.Dashboard (4)
Api\TelemetryApiService.cs (1)
528var signal = Channel.CreateBounded<bool>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)
222var channel = Channel.CreateBounded<OtlpSpan>(new BoundedChannelOptions(1000) 279var channel = Channel.CreateBounded<OtlpLogEntry>(new BoundedChannelOptions(1000)
Telemetry\DashboardTelemetrySender.cs (1)
33var channelOptions = new BoundedChannelOptions(1000)
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
87new 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\aspnetcore\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\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
32private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });