RxJS5 Mongo问题

Question

我有一些使用mongo执行查询的RxJS代码。在RxJS v4中工作很好，但是当我迁移到v.5时，我遇到了一些问题。

以下是一些简化的代码：

// Get a mongo connection
getDb() {
  var connect = Rx.Observable.bindNodeCallback(mongodb.connect)
  return connect(this.options.connection.uri, this.options.connection.options)
}

// Query
return getDb()
  .flatMap((db) => {
    var c = db.collection('foo')
    var obs = Rx.Observable.bindNodeCallback(c.insertMany, c)
    return obs(docs)
  })
  .subscribe(...)

每次我尝试某种查询时，都会出现各种错误。所有错误都与蒙戈代码中不存在的options对象相关。我认为这可能是一个背景问题，但我不确定。

上面的查询会产生(在代码中，未定义的是mongo集合选项对象)

Uncaught TypeError: Cannot read property 'serializeFunctions' of undefined
at BoundNodeCallbackObservable.Collection.insertMany[as callbackFunc](node_modules / mongodb / lib / collection.js: 482: 74)

类似的查询结果如下：

TypeError: Cannot read property 'options' of undefined
at BoundNodeCallbackObservable.Collection.remove[as callbackFunc](node_modules / mongodb / lib / collection.js: 1223: 12)

当我手动包装时，更新会正常工作：

var obs = Rx.Observable.create(function(observer) {
   c.insertMany(docs, function(err, res) {
     if (err) { observer.error(err) } else {
       observer.next(res);
       observer.complet();
      }
    })
  })
  return obs

 // This doesn't:
 var obs = Rx.Observable.bindNodeCallback(c.insertMany, c)
 return obs(docs)

Answer 1

好的。事实证明，bindNodeCallback和bindCallback不允许传递上下文。所以我们需要这样做：

c.insertMany = c.insertMany.bind(c)
var obs = Rx.Observable.bindNodeCallback(c.insertMany)