module SupplyDrop::AsyncEnumerable
Public Instance Methods
each(&block)
click to toggle source
Calls superclass method
# File lib/supply_drop/async_enumerable.rb, line 3 def each(&block) pool = SupplyDrop::ThreadPool.new(SupplyDrop::Util.thread_pool_size) super do |item| pool.schedule(item, &block) end pool.shutdown end
map(&block)
click to toggle source
Calls superclass method
# File lib/supply_drop/async_enumerable.rb, line 11 def map(&block) pool = SupplyDrop::ThreadPool.new(SupplyDrop::Util.thread_pool_size) super do |item| pool.schedule(item, &block) end pool.shutdown end