Contents

module SupplyDrop
  module AsyncEnumerable
    def each(&block)
      self.map do |item|
        Thread.new { block.call(item) }
      end.each(&:join)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
supply_drop-0.6.0	lib/supply_drop/async_enumerable.rb
supply_drop-0.5.0	lib/supply_drop/async_enumerable.rb