diff --git a/lib/puma/plugin/statsd.rb b/lib/puma/plugin/statsd.rb index 89e4905..a77db91 100644 --- a/lib/puma/plugin/statsd.rb +++ b/lib/puma/plugin/statsd.rb @@ -57,7 +57,7 @@ def old_workers def running if clustered? - @stats[:worker_status].map { |s| s[:last_status].fetch(:running, 0) }.inject(0, &:+) + @stats[:worker_status].sum(0) { |s| s[:last_status].fetch(:running, 0) } else @stats.fetch(:running, 0) end @@ -65,7 +65,7 @@ def running def backlog if clustered? - @stats[:worker_status].map { |s| s[:last_status].fetch(:backlog, 0) }.inject(0, &:+) + @stats[:worker_status].sum(0) { |s| s[:last_status].fetch(:backlog, 0) } else @stats.fetch(:backlog, 0) end @@ -73,7 +73,7 @@ def backlog def pool_capacity if clustered? - @stats[:worker_status].map { |s| s[:last_status].fetch(:pool_capacity, 0) }.inject(0, &:+) + @stats[:worker_status].sum(0) { |s| s[:last_status].fetch(:pool_capacity, 0) } else @stats.fetch(:pool_capacity, 0) end @@ -81,7 +81,7 @@ def pool_capacity def max_threads if clustered? - @stats[:worker_status].map { |s| s[:last_status].fetch(:max_threads, 0) }.inject(0, &:+) + @stats[:worker_status].sum(0) { |s| s[:last_status].fetch(:max_threads, 0) } else @stats.fetch(:max_threads, 0) end @@ -89,7 +89,7 @@ def max_threads def requests_count if clustered? - @stats[:worker_status].map { |s| s[:last_status].fetch(:requests_count, 0) }.inject(0, &:+) + @stats[:worker_status].sum(0) { |s| s[:last_status].fetch(:requests_count, 0) } else @stats.fetch(:requests_count, 0) end