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