Class: CDC::Concurrent::ResultCollector

Inherits:
Object
  • Object
show all
Defined in:
lib/cdc/concurrent/result_collector.rb

Overview

Normalizes values returned by concurrent workers.

Class Method Summary collapse

Class Method Details

.failure(error) ⇒ CDC::Core::ProcessorResult

Parameters:

  • error (Exception)

Returns:

  • (CDC::Core::ProcessorResult) 


19
20
21
 
# File 'lib/cdc/concurrent/result_collector.rb', line 19

def self.failure(error)
  CDC::Core::ProcessorResult.failure(error)
end

.normalize(value) ⇒ CDC::Core::ProcessorResult

Parameters:

  • value (Object)

Returns:

  • (CDC::Core::ProcessorResult) 


9
10
11
12
13
14
15
 
# File 'lib/cdc/concurrent/result_collector.rb', line 9

def self.normalize(value)
  return value if value.is_a?(CDC::Core::ProcessorResult)

  CDC::Core::ProcessorResult.success(value)
rescue StandardError => e
  failure(e)
end