27 references to BoundedChannelFullMode
Aspire.Dashboard (1)
Telemetry\DashboardTelemetrySender.cs (1)
35FullMode = BoundedChannelFullMode.DropOldest,
Microsoft.AspNetCore.SignalR.Client.Core (1)
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\SignalR\common\Shared\MessageBuffer.cs (1)
32private readonly Channel<long> _waitForAck = Channel.CreateBounded<long>(new BoundedChannelOptions(1) { FullMode = BoundedChannelFullMode.DropOldest });
System.Threading.Channels (24)
System\Threading\Channels\BoundedChannel.cs (10)
17private readonly BoundedChannelFullMode _mode; 53/// <param name="itemDropped">Delegate that will be invoked when an item is dropped from the channel. See <see cref="BoundedChannelFullMode"/>.</param> 54internal BoundedChannel(int bufferedCapacity, BoundedChannelFullMode mode, bool runContinuationsAsynchronously, Action<T>? itemDropped) 412else if (parent._mode == BoundedChannelFullMode.Wait) 418else if (parent._mode == BoundedChannelFullMode.DropWrite) 431T droppedItem = parent._mode == BoundedChannelFullMode.DropNewest ? 490if (parent._items.Count < parent._bufferedCapacity || parent._mode != BoundedChannelFullMode.Wait) 569else if (parent._mode == BoundedChannelFullMode.Wait) 593else if (parent._mode == BoundedChannelFullMode.DropWrite) 606T droppedItem = parent._mode == BoundedChannelFullMode.DropNewest ?
System\Threading\Channels\Channel.cs (4)
36/// Channels created with this method apply the <see cref="BoundedChannelFullMode.Wait"/> 41capacity > 0 ? new BoundedChannel<T>(capacity, BoundedChannelFullMode.Wait, runContinuationsAsynchronously: true, itemDropped: null) : 42capacity == 0 ? new RendezvousChannel<T>(BoundedChannelFullMode.Wait, runContinuationsAsynchronously: true, itemDropped: null) : 56/// <param name="itemDropped">Delegate that will be called when item is being dropped from channel. See <see cref="BoundedChannelFullMode"/>.</param>
System\Threading\Channels\ChannelOptions.cs (7)
48private BoundedChannelFullMode _mode = BoundedChannelFullMode.Wait; 80public BoundedChannelFullMode FullMode 87case BoundedChannelFullMode.Wait: 88case BoundedChannelFullMode.DropNewest: 89case BoundedChannelFullMode.DropOldest: 90case BoundedChannelFullMode.DropWrite:
System\Threading\Channels\RendezvousChannel.cs (3)
46/// <param name="itemDropped">Delegate that will be invoked when an item is dropped from the channel. See <see cref="BoundedChannelFullMode"/>.</param> 47internal RendezvousChannel(BoundedChannelFullMode mode, bool runContinuationsAsynchronously, Action<T>? itemDropped) 49_dropWrites = mode is not BoundedChannelFullMode.Wait;