RxJS.fromCallback()不适用于MySqlJs查询方法

Question

 var query = Rx.Observable.fromCallback(dbConnection.query);
 var obs = query('select * from mytable where id = ?', ['389']);
 obs.subscribe(
     function(e) = {}
 );

这段代码给了我TypeError:无法读取未定义的属性'typeCast‘。

MySqlJs查询方法的文档如下所示：

connection.query('SELECT * FROM `books` WHERE `author` = ?', ['David'], function (error, results, fields)

当我记录查询时，它会返回函数。我做错了什么？

Answer 1

query函数将被传递给fromCallback，但是当它被调用时，它将不会绑定到dbConnection。

你应该这样做：

Rx.Observable.fromNodeCallback(dbConnection.query.bind(dbConnection));

而且，您可能需要fromNodeCallback。