module DDP::Server::RethinkDB::Helpers
Helper class that users can extend to implement an API
that can be passed as the RPC API
parameter to the RethinkDB
DDP
protocol
Public Instance Methods
wrap_changes(query, conn, on_update)
click to toggle source
# File lib/ddp/server/rethinkdb/helpers.rb, line 17 def wrap_changes(query, conn, on_update) query.changes().run(conn).each do |change| old_value = change['old_val'] new_value = change['new_val'] on_update.call(old_value, new_value) end conn.close end
wrap_query(query)
click to toggle source
# File lib/ddp/server/rethinkdb/helpers.rb, line 8 def wrap_query(query) lambda do |&on_update| connection = new_connection results = query.run(connection) results.each { |r| on_update.call(nil, r) } wrap_changes(query, connection, on_update) end end