DownloadSpeedLimiter.cs

using System;
using System.Threading;
using System.Threading.Tasks;
// ReSharper disable UnusedType.Global

namespace Hi3Helper.Http
{
    public class DownloadSpeedLimiter
    {
        public static Func<nint, long, CancellationToken, ValueTask>? AddBytesOrWaitAsyncDelegate;

        public nint Context { get; }

        private DownloadSpeedLimiter(nint serviceContext)
        {
            Context = serviceContext;
        }

        /// <summary>
        /// Create an instance by using current service context.
        /// </summary>
        /// <param name="serviceContext">The context to be used for the service.</param>
        /// <returns>An instance of the speed limiter</returns>
        public static DownloadSpeedLimiter CreateInstance(nint serviceContext)
            => new(serviceContext);

        internal ValueTask AddBytesOrWaitAsync(long readBytes, CancellationToken token)
            => AddBytesOrWaitAsyncDelegate?.Invoke(Context, readBytes, token) ?? ValueTask.CompletedTask;
    }
}