15 references to CreateBounded
aspire (4)
Backchannel\ResourceSnapshotWatcher.cs (1)
41_updateSignal = Channel.CreateBounded<bool>(
Backchannel\TrayWatchStream.cs (2)
39var updates = Channel.CreateBounded<Update>(new BoundedChannelOptions(1) 45var healthChanges = Channel.CreateBounded<bool>(new BoundedChannelOptions(1)
Diagnostics\FileLoggerProvider.cs (1)
102Channel.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.RemoteHost (1)
src\Shared\ChildProcess.cs (1)
694var lines = Channel.CreateBounded<OutputLine>(new BoundedChannelOptions(256)
Aspire.TerminalHost (1)
DcpUpstreamAdapter.cs (1)
86_outputChannel = Channel.CreateBounded<ReadOnlyMemory<byte>>(
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 });