class Actor::Messaging::Send

Constants

QueueFullError

Public Class Methods

call(*arguments) click to toggle source
# File lib/actor/messaging/send.rb, line 22
def self.call *arguments
  instance = new
  instance.(*arguments)
end

Public Instance Methods

call(message, address, wait: nil) click to toggle source
# File lib/actor/messaging/send.rb, line 4
def call message, address, wait: nil
  non_block = !wait

  queue = address.queue

  if message.instance_of? ::Module
    message = message.message_name
  end

  begin
    queue.enq message, non_block
  rescue ThreadError
    raise QueueFullError
  end
end