1 instantiation of RequestRegistration
System.Threading.RateLimiting (1)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
208
var registration = new
RequestRegistration
(tokenCount, this, cancellationToken);
15 references to RequestRegistration
System.Threading.RateLimiting (15)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (15)
28
private readonly Deque<
RequestRegistration
> _queue = new Deque<
RequestRegistration
>();
158
using var disposer = default(
RequestRegistration
.Disposer);
175
RequestRegistration
oldestRequest = _queue.DequeueHead();
208
var
registration = new RequestRegistration(tokenCount, this, cancellationToken);
290
using var disposer = default(
RequestRegistration
.Disposer);
322
Deque<
RequestRegistration
> queue = _queue;
327
RequestRegistration
nextPendingRequest =
400
using var disposer = default(
RequestRegistration
.Disposer);
411
RequestRegistration
next = _options.QueueProcessingOrder == QueueProcessingOrder.OldestFirst
474
private
RequestRegistration
? _next;
498
if (state is
RequestRegistration
registration && registration.TrySetCanceled(registration._cancellationToken))
520
private
RequestRegistration
? _next;
522
public void Add(
RequestRegistration
request)
530
for (
var
current = _next; current is not null; current = current._next)