class Sorta::Parallel::Worker
Public Class Methods
new(pipe)
click to toggle source
Calls superclass method
# File lib/sorta/parallel/worker.rb, line 4 def self.new(pipe) super(pipe) do |pipe| loop do (task, queue_id, data, index), result_pipe = pipe.take result_pipe.send([task.new.call(data), queue_id, index], move: true) rescue result_pipe.send(Signals::Error.new, move: true) next end end end