Method: Que::Connection#drain_notifications

Defined in:
lib/que/connection.rb

#drain_notifications ⇒ Object 



118
119
120
 
# File 'lib/que/connection.rb', line 118

def drain_notifications
  loop { break if next_notification.nil? }
end