Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions .rubocop.yml
Original file line number Diff line number Diff line change
Expand Up @@ -35,3 +35,7 @@ Gemspec/RequiredRubyVersion:
Gemspec/RequireMFA:
Enabled: false
Severity: warning
Layout/EmptyLinesAfterModuleInclusion:
# avoid false-positives from the instance method `include` being used in specs
Exclude:
- spec/**/*_spec.rb
1 change: 1 addition & 0 deletions lib/flatware/cucumber/formatters/console/summary.rb
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
1 change: 1 addition & 0 deletions lib/flatware/rspec/job_builder.rb
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ module RSpec
# and attempts to ballence the jobs accordingly.
class JobBuilder
extend Forwardable

attr_reader :args, :workers, :configuration

def_delegators(
Expand Down
2 changes: 2 additions & 0 deletions lib/flatware/sink.rb
Original file line number Diff line number Diff line change
Expand Up @@ -32,13 +32,15 @@ def initialize(jobs:, formatter:, sink:, worker_count: 0, **)
@workers = Set.new(worker_count.times.to_a)
end

# rubocop:disable Naming/PredicateMethod
def start
Signal.listen(formatter, &method(:on_interrupt))
formatter.jobs jobs
DRb.start_service(sink, self, verbose: Flatware.verbose?)
DRb.thread.join
!(failures? || interrupted?)
end
# rubocop:enable Naming/PredicateMethod

def ready(worker)
job = queue.shift
Expand Down