Articles of q

用下划线地图做一些asynchronous的事情

function addSomething(data) { var defer = q.defer(); data = _.map(data, function(item) { item['something'] = callSomethingAsync(); return item; }); return defer.promise; } 我如何处理这个问题。 我发现的唯一方法是使用Async.js。 但也许有一个更好的方式使用$ q? 编辑: function getScopes(item) { var defer = q.defer(); var query = "SELECT somevalue FROM Something WHERE ID = '" + item.id + "'"; mysql.query(query, function(err, data) { if (err) { […]

Node.js使用Q :: Q.ninvoke链承诺

我试图缩小与我的node.js服务器有关的内存问题的潜在原因。 我一直感到有点不舒服的一部分代码是我使用Q的承诺。 以下是我的基本结构: var Q = require('q'); MyClass.prototype.doSomething = function(somedata, callback) { var res = [];// will contain the results of each function call Q.ninvoke(this, 'doSomethingElse', 'hello!') .then((function(result){ res.push(result); return Q.ninvoke(this.someobject, 'someFunction', somedata); }).bind(this)) .then((function(result){ res.push(result); callback(null, res);// Returns both result objects, in an array }).bind(this)) .fail(callback) .done(); } 这看起来合乎逻辑吗? 如果doSomethingElse函数也使用promise,该怎么办? 这里的一切都是正确的吗?

是否有像node.js中的延迟(Q)监视器?

我希望看到所有未解决的状态(如果可能的话,所有的延迟日志:初始化,未解决,已解决/拒绝状态)。 有没有什么机制呢? 例如: Q.getAllDeferreds()或Q.getLog()

node.js&promise:常见的做法?

我是node.js新手,现在正在设置环境,select使用哪些模块等等。在我的研究中,我发现了Q模块 – 我真的很欣赏,因为代码的简单性和结构本身。 我开始寻找关于使用node.js的承诺的利弊的讨论。 但不幸的是,我找不到很多信息。 现在我问自己为什么。 你build议使用node.js promises吗? 还是有什么已知的缺点,可能会阻止我使用它?

使用Firebase返回数组

尝试查找使用Firebase .on("child_added")时使用Q库(或任何类似的库,我不是部分)在Node.js中返回数据数组的最佳用法示例。 我尝试过使用Q.all()但它似乎从来没有等待承诺之前填写返回。 这是我现在的例子: function getIndex() { var deferred = q.defer(); deferred.resolve(new FirebaseIndex( Firebase.child('users').child(user.app_user_id).child('posts'), Firebase.child('posts') ) ); return deferred.promise; } function getPost( post ) { var deferred = q.defer(); deferred.resolve(post.val()); return deferred.promise; } function getPosts() { var promises = []; getIndex().then( function (posts) { posts.on( 'child_added', function (_post) { promises.push( getPost(_post) ); }); }); return […]

如何在使用node.js Q链执行期间插入promise?

我有一个承诺链,请求一个RSS URL,parsing它的链接,然后需要请求每个链接。 第一部分很好。 然而,我有问题的工作如何“插入承诺”,要求每个链接已被parsing。 我开始通过生成一个简单的链接url(首选的方法),但无法做到这一点。 代码现在生成一个promise数组请求每个URL,但我不知道如何使这个工作。 也许我需要使用Q.all(),但似乎是预定义的function? requestRss(rssSourceUrl) .then(function(links) { // ??? }) .catch(function(error) { console.log(error); }) .done(); function requestRss(url) { var deferred = q.defer(); request(url, function(err, resp, body) { if (err || resp.statusCode !== 200) { deferred.reject(new Error(resp.statusCode + ' ' + err + ' ' + body)); } else { $ = cheerio.load(body); […]

如何在Q.then()callback中传播嵌套错误

我觉得这应该很容易,但我一直在挣扎一段时间。 我有看起来像这样的代码(显然这是一个简化的例子)。 getPromise(param1, param2) .then(function (results) { // do something that causes an error: var err1 = new Error() throw err1; }) .then(function (results) { getAnotherPromise(param1) .then(function (res) { // do something else that might cause an error: var err2 = new Error() throw err2; }) }) .then(function (results) { // deal with the results […]

Q promises – 数组中每个元素的Node.js函数

函数dirList()应该返回definded目录内的文件夹数组。 我不明白如何返回dirListvariables只有在函数isDir()执行每个文件。 我想我应该使用Q.all() ,但我不知道我应该把它放在:-( var fs = require('fs'), Q = require('q'), readdir = Q.denodeify(fs.readdir); function isDir(path) { return Q.nfcall(fs.stat, __dirname + path) .then(function (stats) { if (stats.isDirectory()) { return true; } else { return false; } }); } function dirList(path) { return readdir(__dirname + path).then(function (files) { var dirList = files.filter(function (file) { return isDir(path […]

Q承诺不起作用,减lessfunction

我试图返回最早修改date的目录中的文件。 这种方法似乎在createFileDateMap函数中失败。 我想减less一个文件path的数组,并创build一个文件名和MODdate的对象。 getModDate函数是一个asynchronous的fs.lstat调用。 我似乎无法设置我的reducer的acc从.then()块内的值。 当值取决于asynchronous调用时,我不确定如何实现减less var _ = require('lodash'), fs = require('fs'), path = require('path'), Q = require('q'); function checkDir(dir) { // Check if given path is valid directory var deferred = Q.defer(); fs.lstat(dir, deferred.makeNodeResolver()); return deferred.promise.invoke('isDirectory'); } function getFiles(dir) { // Get all files within a directory var deferred = Q.defer(); fs.readdir(dir, deferred.makeNodeResolver()); […]

我怎样才能用“Q`与mongoose绑定`save`方法

说我在User.js有以下模式 var mongoose = require('mongoose'); var Q = require('q'); var userSchema = new mongoose.Schema({ phone: { type: Number, require: true, index: { unique: true } } }); module.exports = mongoose.model('User', userSchema); module.exports.findOne = Q.nfbind(module.exports.findOne.bind(module.exports)); module.exports.find = Q.nfbind(module.exports.find.bind(module.exports)); 另一个文件testuser.js var mongoose = require('mongoose'); var Q = require('q'); var User = require('../User'); var connectionStr = "mongodb://localhost:27017/user-model-test"; mongoose.connect(connectionStr, […]