22 references to BoundedChannelFullMode
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 (20)
System\Threading\Channels\BoundedChannel.cs (10)
17private readonly BoundedChannelFullMode _mode; 45/// <param name="itemDropped">Delegate that will be invoked when an item is dropped from the channel. See <see cref="BoundedChannelFullMode"/>.</param> 46internal BoundedChannel(int bufferedCapacity, BoundedChannelFullMode mode, bool runContinuationsAsynchronously, Action<T>? itemDropped) 415else if (parent._mode == BoundedChannelFullMode.Wait) 421else if (parent._mode == BoundedChannelFullMode.DropWrite) 434T droppedItem = parent._mode == BoundedChannelFullMode.DropNewest ? 499if (parent._items.Count < parent._bufferedCapacity || parent._mode != BoundedChannelFullMode.Wait) 590else if (parent._mode == BoundedChannelFullMode.Wait) 612else if (parent._mode == BoundedChannelFullMode.DropWrite) 625T droppedItem = parent._mode == BoundedChannelFullMode.DropNewest ?
System\Threading\Channels\Channel.cs (3)
38/// Channels created with this method apply the <see cref="BoundedChannelFullMode.Wait"/> 48return new BoundedChannel<T>(capacity, BoundedChannelFullMode.Wait, runContinuationsAsynchronously: true, itemDropped: null); 63/// <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; 77public BoundedChannelFullMode FullMode 84case BoundedChannelFullMode.Wait: 85case BoundedChannelFullMode.DropNewest: 86case BoundedChannelFullMode.DropOldest: 87case BoundedChannelFullMode.DropWrite: