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