From 4bc4fa5804ddd73e598f66cfaef7e30955b428ea Mon Sep 17 00:00:00 2001
From: Keith Rarick <kr@causes.com>
Date: Fri, 20 Jun 2008 14:03:13 -0700
Subject: [PATCH] Add a :fanout_pri option to async_each.

---
 lib/async_observer/extend.rb | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/lib/async_observer/extend.rb b/lib/async_observer/extend.rb
index 52f9bcf..d232376 100644
--- 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)