Method: DataSift::LiveStream#fire_ds_message

Defined in:
lib/live_stream.rb

#fire_ds_message(message) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/live_stream.rb', line 27

def fire_ds_message(message)
  hash = false
  if message.has_key?(:hash)
    hash = message[:hash]
  end
  message.merge!({
    :is_failure => message[:status] == 'failure',
    :is_success => message[:status] == 'success',
    :is_warning => message[:status] == 'warning',
    :is_tick    => message[:status] == 'connected'
  })
  @on_datasift_message.call(self, message, hash)
end