Add a :fanout_pri option to async_each.

kristjan · Jun 20, 2008 · 4bc4fa5 · 4bc4fa5
1 parent dd939e9
commit 4bc4fa5
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/async_observer/extend.rb b/lib/async_observer/extend.rb
@@ -72,6 +72,8 @@ def async_each_opts(rcv, selector, opts, *extra)
     else
       fanout_opts = opts.merge(:fuzz => opts.fetch(:fanout_fuzz,
                                                    DEFAULT_FANOUT_FUZZ))
+      fanout_opts[:pri] = opts[:fanout_pri] || opts[:pri]
+      fanout_opts = fanout_opts.compact
       split_to(fanout_degree) do |subrange|
         subrange.async_send_opts(:async_each_opts, fanout_opts, rcv, selector,
                                  opts, *extra)