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