Sha256: dfc57285473140e2b68cd736ef34cd4ba589e1f56b8f37d51a8660857908fc53

Contents?: true

Size: 437 Bytes

Versions: 11

Compression:

Stored size: 437 Bytes

Contents

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

Version data entries

11 entries across 11 versions & 1 rubygems

Version Path
supply_drop-1.0.0.beta2 lib/supply_drop/async_enumerable.rb
supply_drop-1.0.0.beta1 lib/supply_drop/async_enumerable.rb
supply_drop-0.17.0 lib/supply_drop/async_enumerable.rb
supply_drop-0.16.1 lib/supply_drop/async_enumerable.rb
supply_drop-0.16.0 lib/supply_drop/async_enumerable.rb
supply_drop-0.15.0 lib/supply_drop/async_enumerable.rb
supply_drop-0.13.1 lib/supply_drop/async_enumerable.rb
supply_drop-0.13.0 lib/supply_drop/async_enumerable.rb
supply_drop-0.12.0 lib/supply_drop/async_enumerable.rb
supply_drop-0.11.1 lib/supply_drop/async_enumerable.rb
supply_drop-0.11.0 lib/supply_drop/async_enumerable.rb