Class: OMQ::CLI::GatherRunner

Inherits:

BaseRunner

• Object
• BaseRunner
• OMQ::CLI::GatherRunner

Defined in:

lib/omq/cli/scatter_gather.rb

Overview

Runner for GATHER sockets (draft; fan-in receive).

Instance Attribute Summary

Attributes inherited from BaseRunner

#config, #sock

Instance Method Summary

• #call(task) ⇒ Object

Methods inherited from BaseRunner

#initialize

Constructor Details

This class inherits a constructor from OMQ::CLI::BaseRunner

Instance Method Details

#call(task) ⇒ Object

# File 'lib/omq/cli/scatter_gather.rb', line 13

def call(task)
  config.parallel ? run_parallel_workers(:GATHER) : super
end