@@ -16,7 +16,6 @@ def start(argv)
1616 end
1717
1818 attr_reader :argv , :command
19- attr_accessor :threads , :matrixeval_results
2019
2120 def initialize ( argv )
2221 @argv = argv
@@ -88,7 +87,7 @@ def run_all_contexts_sequentially
8887 docker_compose = DockerCompose . new ( context )
8988 success = docker_compose . run ( command . rest_arguments )
9089
91- self . matrixeval_results << [ context , !!success ]
90+ @ matrixeval_results << [ context , !!success ]
9291 end
9392
9493 report
@@ -145,7 +144,7 @@ def report
145144 table . add_row headers . map { |value | { value : value , alignment : :center } }
146145 table . add_separator
147146
148- matrixeval_results . each do |context , success |
147+ @ matrixeval_results. each do |context , success |
149148 success_cell = [ success ? Rainbow ( 'Success' ) . green : Rainbow ( 'Failed' ) . red ]
150149 row = ( context . variants . map ( &:key ) + success_cell ) . map do |value |
151150 { value : value , alignment : :center }
@@ -160,19 +159,19 @@ def report
160159 end
161160
162161 def parallel ( collection )
163- threads = [ ] unless threads . empty?
164- matrixeval_results = [ ] unless matrixeval_results . empty?
162+ @ threads = [ ] unless @ threads. empty?
163+ @ matrixeval_results = [ ] unless @ matrixeval_results. empty?
165164
166165 collection . each_slice ( per_worker_contexts_count ) do |sub_collection |
167- threads << Thread . new do
166+ @ threads << Thread . new do
168167 yield sub_collection
169168 end
170169 end
171170
172- threads . each ( &:join )
171+ @ threads. each ( &:join )
173172
174- threads . each do |thread |
175- self . matrixeval_results += ( thread [ :matrixeval_results ] || [ ] )
173+ @ threads. each do |thread |
174+ @ matrixeval_results += ( thread [ :matrixeval_results ] || [ ] )
176175 end
177176 end
178177
0 commit comments