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