class Bundler::Fetcher::CompactIndex

def parallel_compact_index_client
  compact_index_client.execution_mode = lambda do |inputs, &blk|
    func = lambda {|object, _index| blk.call(object) }
    worker = bundle_worker(func)
    inputs.each {|input| worker.enq(input) }
    inputs.map { worker.deq }
  end
  compact_index_client
end