Class: Mutant::Runner::Collector

Inherits:
Object
  • Object
show all
Defined in:
lib/mutant/runner/collector.rb

Overview

Parallel process collector

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ undefined

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Initialize object



13
14
15
16
17
18
19
 
# File 'lib/mutant/runner/collector.rb', line 13

def initialize(*)
  super
  @start                = Time.now
  @aggregate            = Hash.new { |hash, key| hash[key] = [] }
  @activity             = Hash.new(0)
  @last_mutation_result = nil
end

Instance Attribute Details

#last_mutation_result ⇒ Result::Mutation? (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Return last mutation result

Returns:



31
32
33
 
# File 'lib/mutant/runner/collector.rb', line 31

def last_mutation_result
  @last_mutation_result
end

Instance Method Details

#active_subject_results ⇒ Array<Result::Subject>

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Return active subject results

Returns:



39
40
41
 
# File 'lib/mutant/runner/collector.rb', line 39

def active_subject_results
  active_subjects.map(&method(:subject_result))
end

#finish(mutation_result) ⇒ self

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Handle mutation finish

Parameters:

Returns:

  • (self) 


79
80
81
82
83
84
85
86
87
88
 
# File 'lib/mutant/runner/collector.rb', line 79

def finish(mutation_result)
  @last_mutation_result = mutation_result

  subject = mutation_result.mutation.subject

  @activity[subject] -= 1
  @aggregate[subject] << mutation_result

  self
end

#result ⇒ Result::Env

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Return current result

Returns:



49
50
51
52
53
54
55
56
 
# File 'lib/mutant/runner/collector.rb', line 49

def result
  Result::Env.new(
    env:             env,
    runtime:         Time.now - @start,
    subject_results: subject_results,
    done:            false
  )
end

#start(mutation) ⇒ self

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Handle mutation start

Parameters:

Returns:

  • (self) 


66
67
68
69
 
# File 'lib/mutant/runner/collector.rb', line 66

def start(mutation)
  @activity[mutation.subject] += 1
  self
end