Permalink
Browse files

Add a :fanout_pri option to async_each.

  • Loading branch information...
1 parent dd939e9 commit 4bc4fa5804ddd73e598f66cfaef7e30955b428ea Keith Rarick committed Jun 20, 2008
Showing with 2 additions and 0 deletions.
  1. +2 −0 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)

0 comments on commit 4bc4fa5

Please sign in to comment.