From d385da49ef6c17c64cf8be66002f5744c1ee38f7 Mon Sep 17 00:00:00 2001
From: elijah <elijah@riseup.net>
Date: Tue, 23 Oct 2012 03:50:52 -0700
Subject: patched supply_drop gem and vendored it

---
 .../supply_drop/lib/supply_drop/async_enumerable.rb   | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)
 create mode 100644 vendor/supply_drop/lib/supply_drop/async_enumerable.rb

(limited to 'vendor/supply_drop/lib/supply_drop/async_enumerable.rb')

diff --git a/vendor/supply_drop/lib/supply_drop/async_enumerable.rb b/vendor/supply_drop/lib/supply_drop/async_enumerable.rb
new file mode 100644
index 0000000..1d5a116
--- /dev/null
+++ b/vendor/supply_drop/lib/supply_drop/async_enumerable.rb
@@ -0,0 +1,19 @@
+module SupplyDrop
+  module AsyncEnumerable
+    def each(&block)
+      pool = SupplyDrop::ThreadPool.new(SupplyDrop::Util.thread_pool_size)
+      super do |item|
+        pool.schedule(item, &block)
+      end
+      pool.shutdown
+    end
+
+    def map(&block)
+      pool = SupplyDrop::ThreadPool.new(SupplyDrop::Util.thread_pool_size)
+      super do |item|
+        pool.schedule(item, &block)
+      end
+      pool.shutdown
+    end
+  end
+end
-- 
cgit v1.2.3