diff options
Diffstat (limited to 'vendor/supply_drop/lib/supply_drop/async_enumerable.rb')
| -rw-r--r-- | vendor/supply_drop/lib/supply_drop/async_enumerable.rb | 19 |
1 files changed, 0 insertions, 19 deletions
diff --git a/vendor/supply_drop/lib/supply_drop/async_enumerable.rb b/vendor/supply_drop/lib/supply_drop/async_enumerable.rb deleted file mode 100644 index 1d5a116..0000000 --- a/vendor/supply_drop/lib/supply_drop/async_enumerable.rb +++ /dev/null @@ -1,19 +0,0 @@ -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 |