class RSpec::Parallel::CommandLine
Public Class Methods
new(options, configuration=RSpec::configuration, world=RSpec::world)
click to toggle source
# File lib/rspec/parallel/command_line.rb, line 4 def initialize(options, configuration=RSpec::configuration, world=RSpec::world) if Array === options options = RSpec::Parallel::ConfigurationOptions.new(options) options.parse_options end @options = options @configuration = configuration @world = world end
Public Instance Methods
run(err, out)
click to toggle source
Configures and runs a suite
@param [IO] err @param [IO] out
# File lib/rspec/parallel/command_line.rb, line 18 def run(err, out) @configuration.error_stream = err @configuration.output_stream ||= out @options.configure(@configuration) @configuration.load_spec_files @world.announce_filters @configuration.reporter.report(@world.example_count, @configuration.randomize? ? @configuration.seed : nil) do |reporter| begin @configuration.run_hook(:before, :suite) group_threads = RSpec::Parallel::ExampleGroupThreadRunner.new(@options.options[:thread_maximum]) @world.example_groups.ordered.map {|g| group_threads.run(g, reporter)} group_threads.wait_for_completion @world.example_groups.all? do |g| result_for_this_group = g.filtered_examples.all? { |example| example.exception.nil? } results_for_descendants = g.children.all? { |child| child.filtered_examples.all? { |example| example.exception.nil? } } result_for_this_group && results_for_descendants end ? 0 : @configuration.failure_exit_code ensure @configuration.run_hook(:after, :suite) end end end