1 instantiation of RequestRegistration
System.Threading.RateLimiting (1)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)
187
var request = new
RequestRegistration
(permitCount, this, cancellationToken);
14 references to RequestRegistration
System.Threading.RateLimiting (14)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (14)
25
private readonly Deque<
RequestRegistration
> _queue = new Deque<
RequestRegistration
>();
135
using var disposer = default(
RequestRegistration
.Disposer);
154
RequestRegistration
oldestRequest = _queue.DequeueHead();
187
var
request = new RequestRegistration(permitCount, this, cancellationToken);
236
using var disposer = default(
RequestRegistration
.Disposer);
253
RequestRegistration
nextPendingRequest =
332
using var disposer = default(
RequestRegistration
.Disposer);
342
RequestRegistration
next = _options.QueueProcessingOrder == QueueProcessingOrder.OldestFirst
424
private
RequestRegistration
? _next;
448
if (state is
RequestRegistration
registration && registration.TrySetCanceled(registration._cancellationToken))
470
private
RequestRegistration
? _next;
472
public void Add(
RequestRegistration
request)
480
for (
var
current = _next; current is not null; current = current._next)