conccurent-ruby sandbox

test.rb

class Processor
  include Concurrent::ActorContext
  
  def receive(msg)
    # do something with the message(s)
    
    <mystery>.post(msg)
  end
end


class DatabaseOutput
  include Concurrent::ActorContext
  
  def receive(msg)
    # save it to the database
  end

end


class ZeromqOutput
  include Concurrent::ActorContext
  
end


processor = Processor.spawn()