16 instantiations of BoundedChannelOptions
aspire (4)
Backchannel\ResourceSnapshotWatcher.cs (1)
42new BoundedChannelOptions(1)
Backchannel\TrayWatchStream.cs (2)
39var updates = Channel.CreateBounded<Update>(new BoundedChannelOptions(1) 45var healthChanges = Channel.CreateBounded<bool>(new BoundedChannelOptions(1)
Diagnostics\FileLoggerProvider.cs (1)
159Channel.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 (3)
Api\TelemetryApiService.cs (1)
528var signal = Channel.CreateBounded<bool>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (2)
221var channel = Channel.CreateBounded<OtlpSpan>(new BoundedChannelOptions(1000) 278var channel = Channel.CreateBounded<OtlpLogEntry>(new BoundedChannelOptions(1000)
Aspire.Hosting (1)
ApplicationModel\TerminalService.cs (1)
307var channel = Channel.CreateBounded<TerminalUpdate>(new BoundedChannelOptions(_dockUpdateBufferCapacity)
Aspire.Hosting.Native.Core (1)
Diagnostics\OperationEventSource.cs (1)
85_channel = Channel.CreateBounded<OperationEvent>(new BoundedChannelOptions(capacity)
Aspire.Hosting.RemoteHost (1)
src\Shared\ChildProcess.cs (1)
694var lines = Channel.CreateBounded<OutputLine>(new BoundedChannelOptions(256)
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
92new 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)
34private 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)
34private 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)
50public static Channel<T> CreateBounded<T>(BoundedChannelOptions options) => 59public static Channel<T> CreateBounded<T>(BoundedChannelOptions options, Action<T>? itemDropped)