Method: DataSift::LiveStream#fire_on_message

Defined in:
lib/live_stream.rb

#fire_on_message(hash, interaction) ⇒ Object 



41
42
43
44
45
46
47
 
# File 'lib/live_stream.rb', line 41

def fire_on_message(hash, interaction)
  callback = @subscriptions[hash]
  if callback == nil
    raise StreamingMessageError.new "no valid on_message callback provided for stream #{hash} with message #{interaction}"
  end
  callback.call(interaction, self, hash)
end