Class: Riffer::Runner

Inherits:

Object

• Object
• Riffer::Runner

Defined in:

lib/riffer/runner.rb,
sig/generated/riffer/runner.rbs

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

• #map(items, context:) {|arg0| ... } ⇒ Array[untyped]

  Maps over items using the provided block.

Instance Method Details

#map(items, context:) {|arg0| ... } ⇒ Array[untyped]

Maps over items using the provided block.

: (Array, context: Riffer::Agent::Context?) { (untyped) -> untyped } -> Array

Parameters:

• (Array[untyped])
• context: (Riffer::Agent::Context, nil)

Yields:

Yield Parameters:

• arg0 (Object)

Yield Returns:

• (Object)

Returns:

• (Array[untyped])

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

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