Module: Actor::Messaging::Publish::Substitute::Assertions

Defined in:
lib/actor/messaging/publish/substitute.rb

Instance Method Summary collapse

Instance Method Details

#published?(message = nil, wait: nil) ⇒ Boolean

Returns:

  • (Boolean) 


50
51
52
53
54
55
56
57
58
59
 
# File 'lib/actor/messaging/publish/substitute.rb', line 50

def published? message=nil, wait: nil
  records.each do |record|
    next unless message.nil? or record.message == message
    next unless wait.nil? or record.wait == wait

    return true
  end

  false
end

#registered?(address = nil) ⇒ Boolean

Returns:

  • (Boolean) 


34
35
36
37
38
39
40
 
# File 'lib/actor/messaging/publish/substitute.rb', line 34

def registered? address=nil
  if address.nil?
    registered_addresses.any?
  else
    registered_addresses.include? address
  end
end

#unregistered?(address = nil) ⇒ Boolean

Returns:

  • (Boolean) 


42
43
44
45
46
47
48
 
# File 'lib/actor/messaging/publish/substitute.rb', line 42

def unregistered? address=nil
  if address.nil?
    unregistered_addresses.any?
  else
    unregistered_addresses.include? address
  end
end