Class RateLimitedHttpMessageHandler

Namespace

Fusillade

Assembly

Fusillade.dll

A http handler which will limit the rate at which we can read.

public class RateLimitedHttpMessageHandler : LimitingHttpMessageHandler, IDisposable

Inheritance

object

HttpMessageHandler

DelegatingHandler

LimitingHttpMessageHandler

RateLimitedHttpMessageHandler

Implements

IDisposable

Inherited Members

DelegatingHandler.Send(HttpRequestMessage, CancellationToken)

DelegatingHandler.Dispose(bool)

DelegatingHandler.InnerHandler

HttpMessageHandler.Dispose()

Extension Methods

ReactiveExtensions.Schedule<T>(T, DateTimeOffset, IScheduler)

ReactiveExtensions.Schedule<T>(T, DateTimeOffset, IScheduler, Action<T>)

ReactiveExtensions.Schedule<T>(T, IScheduler, Func<T, T>)

ReactiveExtensions.Schedule<T>(T, TimeSpan, IScheduler)

ReactiveExtensions.Schedule<T>(T, TimeSpan, IScheduler, Action<T>)

ReactiveExtensions.Schedule<T>(T, TimeSpan, IScheduler, Func<T, T>)

Remarks

Initializes a new instance of the RateLimitedHttpMessageHandler class.

Constructors

RateLimitedHttpMessageHandler(HttpMessageHandler?, Priority, int, long?, OperationQueue?, Func<HttpRequestMessage, HttpResponseMessage, string, CancellationToken, Task>?)

A http handler which will limit the rate at which we can read.

public RateLimitedHttpMessageHandler(HttpMessageHandler? handler, Priority basePriority, int priority = 0, long? maxBytesToRead = null, OperationQueue? opQueue = null, Func<HttpRequestMessage, HttpResponseMessage, string, CancellationToken, Task>? cacheResultFunc = null)

Parameters

handler HttpMessageHandler

The handler we are wrapping.

basePriority Priority

The base priority of the request.

priority int

The priority of the request.

maxBytesToRead long?

The maximum number of bytes we can read.

opQueue OperationQueue

The operation queue on which to run the operation.

cacheResultFunc Func<HttpRequestMessage, HttpResponseMessage, string, CancellationToken, Task>

A method that is called if we need to get cached results.

Remarks

Initializes a new instance of the RateLimitedHttpMessageHandler class.

Methods

ResetLimit(long?)

Resets the total limit of bytes to read. This is usually called when the app resumes from suspend, to indicate that we should fetch another set of data.

public override void ResetLimit(long? maxBytesToRead = null)

Parameters

maxBytesToRead long?

The maximum number of bytes to read.

SendAsync(HttpRequestMessage, CancellationToken)

protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)

Parameters

request HttpRequestMessage

cancellationToken CancellationToken

Returns

Task<HttpResponseMessage>

UniqueKeyForRequest(HttpRequestMessage)

Generates a unique key for a HttpRequestMessage. This assists with the caching.

public static string UniqueKeyForRequest(HttpRequestMessage request)

Parameters

request HttpRequestMessage

The request to generate a unique key for.

Returns

string

The unique key.