diff --git a/lib/async/queue.rb b/lib/async/queue.rb
index 224b2d92..47015a4a 100644
--- 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