项目作者: JamesKyburz
项目描述 :
wait for rethinkdb mutations
高级语言: JavaScript
项目地址: git://github.com/JamesKyburz/rwait.git
rwait



Usage
const r = require('rethinkdbdash')({ host: 'localhost' })
const rwait = require('rwait')(r)
;(async () => {
try {
const pending = await rwait({
db: 'test',
table: 'test',
timeout: 2000,
filter: r.row('new_val')('id').eq('test')
})
// some operation that causes a write somewhere else....
process.nextTick(() => {
r.db('test').table('test').insert([ { id: 'test', value: 'hello world' } ]).run()
})
const value = await pending.value
console.log('got value', value)
} catch (err) {
console.error('error', err)
}
})()
license
Apache License, Version 2.0