如何将async.waterfall与外部异步函数(RedisSMQ)一起使用

Question

我有一个rsmq服务器，它应该检查给定的URL是否包含图像。我需要使程序同步运行，因为有一个init()函数和一个while(true)循环来服务所有请求。

首先在init()函数之前调用循环。

第二个，我希望循环在继续循环之前等待每次迭代完成，这样就不会导致堆溢出。

正在尝试使用async.waterfall。我的代码：Pastebin.com链接

提前感谢！

Answer 1

使用while (true)是一种非常糟糕的做法，因为它会阻塞并会发出大量请求，而不是像您所期望的那样发出一个请求。使用async.during:

async.whaterfall([
    (done) => {
        // do some async stuff
        done(null, false);
    },
    (isLoaded, callback) => { // isLoaded is false
        async.during(
            () => ! isLoaded, // Test async function result
            (done) => { // Run check
                checkIsLoaded((err) => {
                    if (err) {
                        done(err);
                    } else {
                        isLoaded = true;
                    }
                })
            },
            callback
        )
    }
], (err, result) => {
    // result got...
);