rethinkdb-co

rethinkdb-co
============

Harness RethinkDB Callbacks with ECMAScript 6 Generators

Installation

$ npm install rethinkdb-co

Example

var rco = require('rethinkdb-co');
var r = require('rethinkdb');
var co = require('co');

var query = r.tableList();

co(function *() {
// pause and wait for connection
var connection = yield rco.connect();
// pause and wait for result
var result = yield rco.run(query);
console.log('result', result);
// disconnect
yield rco.disconnect();
})();

With koa-rethinkdb

var rethinkdbPool = require('koa-rethinkdb');
var rco = require('rethinkdb-co');
var r = require('rethinkdb');

app.use(rethinkdbPool(options));

app.use(function *(next) {

// get the list of table
var query1 = r.db('test').tableList();

var list = yield rco.run(query1);

// select a few documents
var query2 = r.db('test').table('foobar').limit(10);

result = yield rco.runf(query2);

yield next;
// connections are released back to the pool.
});

methond: run

Return the result you would expect from rethinkdb client.

methond: runf

If the query returns a cursor, run cursor.toArray() for you, since that's probably what you want.

License

MIT