Module: Actor::Messaging::Queue::Substitute::Assertions

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

Instance Method Summary collapse

Instance Method Details

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

Returns:

  • (Boolean) 


47
48
49
50
51
52
53
54
 
# File 'lib/actor/messaging/queue/substitute.rb', line 47

def enqueued? message=nil, wait: nil
  @enqueued_records.any? do |record|
    next unless message.nil? or record.message == message
    next unless wait.nil? or record.non_block == !wait

    true
  end
end