diff options
| author | Samuel Giddins <segiddins@segiddins.me> | 2016-01-10 00:11:01 -0600 |
|---|---|---|
| committer | Samuel Giddins <segiddins@segiddins.me> | 2016-01-25 10:49:51 -0600 |
| commit | c19c34a5404322816610562b1e7f5541329558e2 (patch) | |
| tree | 0ef9394e482e742a27d3451c4da59468d7254b95 | |
| parent | 039ab918fdd5a395bb6447389f5ae0bd48c7d6b3 (diff) | |
| download | bundler-c19c34a5404322816610562b1e7f5541329558e2.tar.gz | |
[CompactIndex] Send the proper arity function to the Worker
| -rw-r--r-- | lib/bundler/fetcher/compact_index.rb | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/bundler/fetcher/compact_index.rb b/lib/bundler/fetcher/compact_index.rb index fcd5e51269..1f534d9c9a 100644 --- a/lib/bundler/fetcher/compact_index.rb +++ b/lib/bundler/fetcher/compact_index.rb @@ -78,7 +78,8 @@ module Bundler CompactIndexClient.new(cache_path, compact_fetcher) end.tap do |client| client.in_parallel = lambda do |inputs, &blk| - worker = Bundler::Worker.new(25, blk) + func = lambda {|object, _index| blk.call(object) } + worker = Bundler::Worker.new(25, func) inputs.each {|input| worker.enq(input) } inputs.map { worker.deq } end |