Method: DDP::Server::Protocol::Data#handle_sub

Defined in:
lib/ddp/server/protocol/data.rb

#handle_sub(id, name, params) ⇒ Object 



21
22
23
24
25
26
27
28
29
 
# File 'lib/ddp/server/protocol/data.rb', line 21

def handle_sub(id, name, params)
  params ||= []
  query = api.collection_query(name, *params)
  subscription = subscriptions[id] = Subscription.new(self, id, name, query)
  subscription.async.start
  send_ready([id])
rescue => e
  send_error_result(id, e)
end