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