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