# 实时推送

const tcb = require('tcb-js-sdk');

const app = tcb.init({
  env: "xxxx"
});
// 1. 获取数据库引用
var db = app.database();

const watcher = db.collection('todos').where({
  // query...
}).watch({
  onChange: function(snapshot) {
    console.log('snapshot', snapshot)
  },
  onError: function(err) {
    console.error('the watch closed because of error', err)
  }
})

// 1. 获取数据库引用
const db = wx.cloud.database();

const watcher = db.collection('todos').where({
  // query...
}).watch({
  onChange: function(snapshot) {
    console.log('snapshot', snapshot)
  },
  onError: function(err) {
    console.error('the watch closed because of error', err)
  }
})

watcher.close()

watcher.close()