class Riffer::Runner

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

Source

# File lib/riffer/runner.rb, line 10
def map(items, context:, &block)
  raise NotImplementedError, "#{self.class} must implement #map"
end

Maps over items using the provided block.