[CompactIndex] Fetch in parallel using Bundler::Worker

1 files changed, 7 insertions, 0 deletions

diff --git a/lib/bundler/fetcher/compact_index.rb b/lib/bundler/fetcher/compact_index.rb
index d58c1659..7381846b 100644
--- a/lib/bundler/fetcher/compact_index.rb
+++ b/lib/bundler/fetcher/compact_index.rb
@@ -1,4 +1,5 @@
 require "bundler/fetcher/base"
+require "bundler/worker"
 
 module Bundler
   class Fetcher
@@ -69,6 +70,12 @@ module Bundler
 
           SharedHelpers.filesystem_access(cache_path) do
             CompactIndexClient.new(cache_path, compact_fetcher)
+          end.tap do |client|
+            client.in_parallel = lambda do |inputs, &blk|
+              worker = Bundler::Worker.new(25, blk)
+              inputs.each {|input| worker.enq(input) }
+              inputs.map { worker.deq }
+            end
           end
         end
       end