Method: Miu::Subscriber#run

Defined in:
lib/miu/subscriber.rb

#run ⇒ Object 



59
60
61
62
63
64
65
66
67
 
# File 'lib/miu/subscriber.rb', line 59

def run
  @subscriber.each do |packet|
    begin
      on_packet packet
    rescue Exception => e
      Miu::Logger.exception e
    end
  end
end