Allow forwarding options to Queue#async.

socketry · Jul 12, 2024 · 713ecbc · 713ecbc
1 parent bed3499
commit 713ecbc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/async/queue.rb b/lib/async/queue.rb
@@ -48,9 +48,9 @@ def dequeue
 			@items.shift
 		end
 
-		def async(parent: (@parent or Task.current), &block)
+		def async(parent: (@parent or Task.current), **options, &block)
 			while item = self.dequeue
-				parent.async(item, &block)
+				parent.async(item, **options, &block)
 			end
 		end