listener = firestore.col(collection_path).listen do |snapshot|
snapshot.changes.each do |change|
puts "New city: #{change.doc.document_id}" if change.added?
end
end
# Register to be notified when unhandled errors occur.
listener.on_error do |error|
puts "Listen failed: #{error.message}"
end