1 instantiation of RequestRegistration
System.Threading.RateLimiting (1)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
209var registration = new RequestRegistration(tokenCount, this, cancellationToken);
15 references to RequestRegistration
System.Threading.RateLimiting (15)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (15)
28private readonly Deque<RequestRegistration> _queue = new Deque<RequestRegistration>(); 159using var disposer = default(RequestRegistration.Disposer); 176RequestRegistration oldestRequest = _queue.DequeueHead(); 209var registration = new RequestRegistration(tokenCount, this, cancellationToken); 291using var disposer = default(RequestRegistration.Disposer); 323Deque<RequestRegistration> queue = _queue; 328RequestRegistration nextPendingRequest = 401using var disposer = default(RequestRegistration.Disposer); 412RequestRegistration next = _options.QueueProcessingOrder == QueueProcessingOrder.OldestFirst 475private RequestRegistration? _next; 499if (state is RequestRegistration registration && registration.TrySetCanceled(registration._cancellationToken)) 521private RequestRegistration? _next; 523public void Add(RequestRegistration request) 531for (var current = _next; current is not null; current = current._next)