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