Class: Riffer::Runner

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

Overview

Generic concurrency primitive for batch execution. Subclasses implement map to control how items are processed.

Direct Known Subclasses

Fibers, Sequential, Threaded

Defined Under Namespace

Classes: Fibers, Sequential, Threaded

Instance Method Summary collapse

Instance Method Details

#map(items, context:, &block) ⇒ Object

Maps over items using the provided block. – : (Array, context: Riffer::Agent::Context?) { (untyped) -> untyped } -> Array

Raises:

  • (NotImplementedError) 


10
11
12
 
# File 'lib/riffer/runner.rb', line 10

def map(items, context:, &block)
  raise NotImplementedError, "#{self.class} must implement #map"
end