Method: DataSift::LiveStream#subscribe

Defined in:
lib/live_stream.rb

#subscribe(hash, on_message) ⇒ Object

Raises:



49
50
51
52
53
 
# File 'lib/live_stream.rb', line 49

def subscribe(hash, on_message)
  raise BadParametersError.new('on_message - 3 parameters required') unless on_message.arity == 3
  @subscriptions[hash] = on_message
  @stream.send "{ \"action\":\"subscribe\",\"hash\":\"#{hash}\"}"
end