class Actor::Messaging::Address
Public Class Methods
build(max_queue_size: nil)
click to toggle source
# File lib/actor/messaging/address.rb, line 6 def self.build max_queue_size: nil id = SecureRandom.uuid queue = Queue.get max_size: max_queue_size new id, queue end
Public Instance Methods
actors_waiting()
click to toggle source
# File lib/actor/messaging/address.rb, line 13 def actors_waiting queue.num_waiting end
queue_depth()
click to toggle source
# File lib/actor/messaging/address.rb, line 17 def queue_depth queue.size end
queue_limit()
click to toggle source
# File lib/actor/messaging/address.rb, line 21 def queue_limit queue.max end