Fix rubocop failures

Author: obrie

.rubocop.yml

@@ -25,6 +25,9 @@ Style/FrozenStringLiteralComment:
 Naming/FileName:
   Exclude:
     - lib/flatware-*.rb
+Naming/PredicateMethod:
+  Exclude:
+    - lib/flatware/sink.rb
 Style/Documentation:
   Enabled: false
 Metrics/BlockLength:

lib/flatware/cucumber/formatters/console/summary.rb

@@ -7,6 +7,7 @@ module Formatters
       class Console
         class Summary
           include ::Cucumber::Formatter::Console
+
           attr_reader :io, :steps, :scenarios
 
           def initialize(steps, scenarios = [], io = StringIO.new)

lib/flatware/pid.rb

@@ -27,9 +27,9 @@ def self.ps
         .popen(['ps', *args])
         .readlines
         .map do |row|
-        fields = row.strip.split(/\s+/, 4)
-        new(*fields.take(3).map(&:to_i), fields.last)
-      end
+          fields = row.strip.split(/\s+/, 4)
+          new(*fields.take(3).map(&:to_i), fields.last)
+        end
     end
 
     def pids_of_group(group_pid)

lib/flatware/rspec/formatters/console.rb

@@ -63,12 +63,12 @@ def spec_list(remaining)
           remaining
             .flat_map(&:id).sort.each_with_index
             .map do |example, index|
-            format(
-              '%<index>4d) %<example>s',
-              index: index.next,
-              example: example
-            )
-          end.join("\n")
+              format(
+                '%<index>4d) %<example>s',
+                index: index.next,
+                example: example
+              )
+            end.join("\n")
         end
 
         def colorizer

lib/flatware/rspec/job_builder.rb

@@ -9,6 +9,7 @@ module RSpec
     # and attempts to ballence the jobs accordingly.
     class JobBuilder
       extend Forwardable
+
       attr_reader :args, :workers, :configuration
 
       def_delegators(
@@ -54,12 +55,12 @@ def timed_and_untimed_files(seconds_per_file)
         files_to_run
           .map(&method(:normalize_path))
           .reduce([[], []]) do |(timed, untimed), file|
-          if (time = seconds_per_file[file])
-            [timed + [[file, time]], untimed]
-          else
-            [timed, untimed + [file]]
+            if (time = seconds_per_file[file])
+              [timed + [[file, time]], untimed]
+            else
+              [timed, untimed + [file]]
+            end
           end
-        end
       end
 
       def normalize_path(path)
@@ -73,14 +74,15 @@ def load_persisted_example_statuses
       end
 
       def sum_seconds(statuses)
-        statuses.select(&passing)
-                .map { |example| parse_example(**example) }
-                .reduce({}) do |times, example|
-          times.merge(
-            example.fetch(:file_name) => example.fetch(:seconds)
-          ) do |_, old = 0, new|
-            old + new
-          end
+        statuses
+          .select(&passing)
+          .map { |example| parse_example(**example) }
+          .reduce({}) do |times, example|
+            times.merge(
+              example.fetch(:file_name) => example.fetch(:seconds)
+            ) do |_, old = 0, new|
+              old + new
+            end
         end
       end
 
@@ -109,10 +111,10 @@ def balance_by(count, items, &block)
             .sort_by(&block)
             .reverse
             .each do |entry|
-            groups.min_by do |group|
-              group.map(&block).reduce(:+) || 0
-            end.push(entry)
-          end
+              groups.min_by do |group|
+                group.map(&block).reduce(:+) || 0
+              end.push(entry)
+            end
         end
       end
     end

lib/flatware/sink.rb

@@ -117,8 +117,8 @@ def group_jobs(jobs, worker_count)
           .with_index { |_, i| i % worker_count }
           .values
           .map do |job_group|
-          Job.new(job_group.map(&:id).flatten, jobs.first.args)
-        end
+            Job.new(job_group.map(&:id).flatten, jobs.first.args)
+          end
       end
     end
   end

spec/flatware/sink/signal_spec.rb

@@ -53,7 +53,7 @@ def send_signal(signal)
     end
 
     it 'tells the formatter to emit the signal message' do
-      expect(messages).to match([include(expected_message), 'done.'])
+      expect(messages).to match([match(expected_message), 'done.'])
     end
 
     it 'calls on_interrupt' do