Contents

# frozen_string_literal: true

module Mutant
  module Runner
    class Sink
      include Concord.new(:env)

      # Initialize object
      #
      # @return [undefined]
      def initialize(*)
        super
        @start           = Timer.now
        @subject_results = {}
      end

      # Runner status
      #
      # @return [Result::Env]
      def status
        Result::Env.new(
          env:             env,
          runtime:         Timer.now - @start,
          subject_results: @subject_results.values
        )
      end

      # Test if scheduling stopped
      #
      # @return [Boolean]
      def stop?
        status.stop?
      end

      # Handle mutation finish
      #
      # @param [Result::Mutation] mutation_result
      #
      # @return [self]
      def result(mutation_result)
        subject = mutation_result.mutation.subject

        @subject_results[subject] = Result::Subject.new(
          subject:          subject,
          mutation_results: previous_mutation_results(subject) + [mutation_result],
          tests:            env.selections.fetch(subject)
        )

        self
      end

    private

      # Return previous results
      #
      # @param [Subject]
      #
      # @return [Array<Result::Mutation>]
      def previous_mutation_results(subject)
        subject_result = @subject_results.fetch(subject) { return EMPTY_ARRAY }
        subject_result.mutation_results
      end

    end # Sink
  end # Runner
end # Mutant

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
mutant-0.9.8	lib/mutant/runner/sink.rb
mutant-0.9.7	lib/mutant/runner/sink.rb
mutant-0.9.6	lib/mutant/runner/sink.rb
mutant-0.9.5	lib/mutant/runner/sink.rb
mutant-0.9.4	lib/mutant/runner/sink.rb
mutant-0.9.3	lib/mutant/runner/sink.rb
mutant-0.9.2	lib/mutant/runner/sink.rb
mutant-0.9.1	lib/mutant/runner/sink.rb
mutant-0.9.0	lib/mutant/runner/sink.rb