ztimer
Advanced tools
+2
-2
@@ -42,3 +42,3 @@ require "ztimer/version" | ||
| def concurrency=(new_value) | ||
| raise ArgumentError.new("Invalid concurrency value: #{new_value}") unless new_value.is_a?(Fixnum) && new_value > 1 | ||
| raise ArgumentError.new("Invalid concurrency value: #{new_value}") unless new_value.is_a?(Fixnum) && new_value >= 1 | ||
| @concurrency = new_value | ||
@@ -63,3 +63,3 @@ end | ||
| begin | ||
| while !@queue.empty? && @queue.pop(true) do | ||
| while !@queue.empty? && (slot = @queue.pop(true)) do | ||
| slot.executed_at = utc_microseconds | ||
@@ -66,0 +66,0 @@ slot.callback.call(slot) unless slot.callback.nil? |
| module Ztimer | ||
| VERSION = "0.4.1" | ||
| VERSION = "0.4.2" | ||
| end |