ThroughputMessageHandler

gistfile1.cs

  public class ThroughputMessageHandler : DelegatingHandler
    {
        private readonly ILogger _logger;
        private Timer _timer;
        private int _count;
        public ThroughputMessageHandler(ILogger logger)
        {
            _logger = logger;
            _count = 0;
            _timer = new Timer(new TimerCallback(timerCallback),null,1000,1000);
            
        }
        private void timerCallback(object  state)
        {
            _logger.Log("perf",TraceLevel.Verbose,() => _count + " req/sec"); 
            _count = 0;
        }
        protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
        {

            return base.SendAsync(request, cancellationToken)
                .ContinueWith((t) => { 
                    lock (this)
                    {
                        _count++;
                    }
                    
                    return t.Result;
            });
        }
    }