Sha256: 6c50b8be264caeea119ca61bb216109055b3edb0eb690ce400cf136a3cf1e6f4

Contents?: true

Size: 409 Bytes

Versions: 5

Compression:

Stored size: 409 Bytes

Contents

# frozen_string_literal: true

# Released under the MIT License.
# Copyright, 2024, by Samuel Williams.

require_relative "../../../async/task"
require "metrics/provider"

Metrics::Provider(Async::Task) do
	ASYNC_TASK_SCHEDULED = Metrics.metric("async.task.scheduled", :counter, description: "The number of tasks scheduled.")
	
	def schedule(&block)
		ASYNC_TASK_SCHEDULED.emit(1)
		
		super(&block)
	end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
async-2.21.3 lib/metrics/provider/async/task.rb
async-2.21.2 lib/metrics/provider/async/task.rb
async-2.21.1 lib/metrics/provider/async/task.rb
async-2.21.0 lib/metrics/provider/async/task.rb
async-2.20.0 lib/metrics/provider/async/task.rb