Method: DDP::Server::Protocol::Data#subscription_update

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

#subscription_update(id, old_value, new_value) ⇒ Object



31
32
33
34
35
36
37
38
# File 'lib/ddp/server/protocol/data.rb', line 31

def subscription_update(id, old_value, new_value)
	subscription_name = @subscriptions[id].name

	return send_added(subscription_name, new_value['id'], new_value) if old_value.nil?
	return send_removed(subscription_name, old_value['id']) if new_value.nil?

	send_changed(subscription_name, old_value['id'], new_value, old_value.keys - new_value.keys)
end