Tag: asynchronous

node-horsemanasynchronous不起作用？: 我正在使用node-horseman（希望）允许我执行asynchronousphantomjs操作来实现asynchronous无头浏览。数组中的数字在这个阶段是不相关的，我只是将代码剥离到最低限度，以演示我遇到的问题。当我运行下面的代码时，它运行asynchronous，但是，一旦我创build一个新的骑士，它将停止asynchronous运行。我知道它没有运行asynchronous，因为输出（控制台logging数字）以线性方式发生，每个数字在统一的时间之后显示。运行它asynchronous它应该是瞬间的，因为显示每一个的开销应该是相同的，所以所有的数字应该同时出现在他们没有创build骑马对象时的方式（如下面的代码对象禁用）。 var Horseman = require('node-horseman'); var async = require('async'); var testArray = [ 1, 2, 3, 4, 5 ]; function evaluate( item ) { console.log( item ); /*It runs asynchronously but if the two lines below are activated it stops being async and runs synchronously, defeating the whole purpose of using […]

我怎么能promisify我写的一个简单的asynchronous函数？: build立在为Node编写一些数字Javascript代码的时候，发生了这样的想法：“为什么不使这个asynchronous呢？例如， var mySquare = function(x, callback) { callback(null, x * x); } mySquare(3, function(err, res) { console.log(res); }); // prints 9 除非有更复杂的计算，而且可能会引发错误。题我怎么promisify这个function，而不重写它使用承诺？使用蓝鸟的promisify ，通过var promisedSquare = Promise.promisify(mySquare) ，返回一个错误堆栈： TypeError: undefined is not a function at l (/path/bluebird.min.js:30:15474) at Function.e.promisify (/path/bluebird.min.js:30:16031) at repl:1:30 … 它几乎看起来像蓝鸟试图评估mySquare 。我没有像d3.json （包装XHR）promisifying库函数没有问题，所以我很困惑：我需要提供比任何比callback驱动的asynchronous函数更多的蓝鸟？

async.each在完成所有迭代后callback: 现在我已经一头撞在这段代码上几个小时了。而且我之前多次使用过“ async.each ”。可能是代码只是需要一组不同的眼睛来工作。这是代码和问题。 async.each(process.argv, function(file, callback){ runFile(file, callback); }, function(err){ console.log("Here is the error!:" + err +"files to unstage: " + filesToUnstage) if(err) console.log(err); else{ if(filesToUnstage) { __unstage(); } } }); RUNFILE： function runFile(filename, callback) { // Do a bunch of stuff …. __parseOutput(output, callback); } __parseOutput： function __parseOutput(output, callback){ //Do some […]

Meteor wrapAsync不会在客户端返回值: 我正在尝试使用Meteor.wrapAsync使用Slingshot上传文件，然后获取上传URL。我已经创build了这个函数，但是当我运行它时，image_url会变成未定义的。该图像虽然成功上传。获取图片url var uploadSlingshotFileSync = Meteor.wrapAsync(uploadSlingshotFile); image_url = uploadSlingshotFileSync(image_file); console.log(image_url); function uploadSlingshotFile = function(file, callback) { var uploader = new Slingshot.Upload("photoUploads"); uploader.send(file, function (error, uploadURL) { callback(null, uploadURL); }); }; 有什么我想念wrapAsync的语法？

pipe道过滤和lodash处理: 我有以下lodash伪代码，这将处理auctions ： var auctions = [{'item': 12345, …}, {'item': 12345, …}, {'item':23436, …}]; var process = function(auctions) { _(auctions) .groupBy('item') .thru(processSpecialItems) .each(processCommonItems) .value(); } 每个函数都依赖于前一个函数的结果，但在processSpecialItems和processCommonItems的情况下：只有特定的item ，即。由给定item值标识的组将由processSpecialItems处理。只有那些没有被处理的团体应该继续处理共同的processCommonItems 。这些操作是CPU密集型的，涉及数据库访问。问题：我怎样才能过滤这些特殊的物品，处理它们，然后把剩下的东西还回来？最好尽可能less的通过，因为data包含超过40,000个项目。使用同步迭代是否可接受，性能明智？这段代码将被执行400次（全部在同一时间）。

使用MariaDB批量插入和删除Waterline / Sails.js: 在我的Sails.js应用程序中，我有一个表auctions ，它包含从Battle.net API最后一次转储所收到的数据。因此，每当一个realm的新的转储到达时，我需要清除所有与这个realm相关的行，然后插入新的领域。我可以这样做：一次性发送（使用destroy()发送一个查询，另一个使用自身的转储）; 或者小批量（按item分组，然后用realm和项目destroy()所有logging，然后插入新logging）。我目前正在使用async.forEachOfSeries来完成上述的小批量操作，但是当前的负载（每次运行作业时都会插入45k条logging），速度太慢了，这并不考虑是否需要更新item工具提示logging。如果我试图一次插入它们，Node.js会启动分页并挂起，或者MariaDB比Waterline允许的时间要长。我怎样才能更加可扩展地解决这个问题？会async.queue或async.cargo工作？

如何在Node.js中创build一个API请求响应stream？: 我从一段时间以来一直在使用Node.js的asynchronousfunction。但是我陷入了一个有趣的问题。基本上我有2个API，我需要一个接一个地调用。由于Node.js的asynchronous性质，我不能检索第一个API请求的响应，直到它完成并调用相应的callback函数。我想要做的是，我想要将第一个API作为请求负载的响应传递给第二个API，而不是等到第一个API完全完成。作为一种可能的替代scheme，我应该从构buildrest API转换到streamAPI吗？任何指针如何做到这一点？谢谢

等待NodeJS中的asynchronous方法: 我看起来高低，只能find如何编写asynchronous函数，我已经明白了。我试图做的是在触发的事件[EventEmitter]中运行asynchronous方法，但是这样一个简单的事情似乎只是根本不可能，因为我可以find。考虑以下… // Your basic async method.. function doSomething(callback) { var obj = { title: 'hello' }; // Fire an event for event handlers to alter the object. // EvenEmitters are called synchronously eventobj.emit('alter_object', obj); callback(null, obj); } // when this event is fired, I want to manipulate the data eventobj.on('alter_object', function(obj) { obj.title […]

Nodejs混合了asynchronous函数和promise: 所以我有一些帮助服务的应用程序，使它更容易创build和获得复杂的模型。其中一个是 getMerits: function(profileId, limit){ return async.waterfall([ function(callback){ Merit.find({employeeProfile: profileId}).then(function(merits){ callback(null, merits); }); }, function(merits, callback){ async.forEach(merits, function(item, loop_callback){ MeritIndex.findOne({id: item.index}).then(function(meritIndex){ merits[merits.indexOf(item)].index = meritIndex; loop_callback(); }); }, function(err, results){ callback(null, merits); }); } ], function(err, results){ return results; }); } 麻烦的是当我试图调用这个函数来得到结果（插入价值指数列表）我不能找出正确的方法来从asynchronous瀑布返回结果： async.forEach(profiles, function(item, loop_callback){ MeritService.getMerits(item.id, 5).exec(function(err, merits){ console.log(merits) profiles[profiles.indexOf(item)].merits = merits; loop_callback(); }); // MeritService.getMerits(item.id, […]

nodeJSdevise模式打破了asynchronousstream水或承诺。然后，然后: 我有4个asynchronous函数在瀑布式我的节点应用程序中执行。 async.waterfall会把它整理一下，但是根据第一个函数的结果，我要么是错误的，要么进行瀑布或者是爆发到完成的function。目前没有办法做到这一点（除了错误，成功的价值，只是闻起来不好）。我正在看使用诺言（蓝鸟），但是，我再也看不到有什么办法可以突破，如果我没有在那个时候再给出另外一个诺言，那么下面的所有内容都会被执行。参数。有其他的模式/工具可以帮助吗？或者我在想这个，只是调用第一个方法，然后根据结果运行async.waterfall，或返回结果！假设我有4个函数可以调用，a，b，c，d ….. async.waterfall([ function(cb) { a("some data", cb) }, function(data, cb) { if(data) { // HERE we want to skip the remaining waterfall a go to the final func } else { b("some data", cb); } }, c, d ], function(err, data) { //do something }); 或者如果他们是承诺… a("some data") […]