class RactorPool::Worker

Public Class Methods

new(*args) { |data, logger| ... } click to toggle source
# File lib/ractor_pool/worker.rb, line 4
def initialize(*args)
  Ractor.new(args) do |worker_id, jobs_pipe, _results_pipe, logger|
    # logger = Logger.new($stdout)
    jobs_pipe.subscribe do |data|
      logger.debug("Worker #{worker_id}: received data: #{data}")
      yield(data, logger)
    end
  end
end