How to use the waterfall function from async

jav.js

GitHub: raawaa/jav-scrapy

71
72
73
74
75
76
77
78
79
80

async.during(
    pageExist,
    // when page exist
    function (callback) {
        async.waterfall(
            [parseLinks, getItems],
            function (err) {
                pageIndex++;
                if (err) return callback(err);

214

974

47

objectDelete.js

GitHub: scality/cloudserver

52
53
54
55
56
57
58
59
60
61
        });
    });
});

it('should keep the null version if versioning enabled', done => {
    async.waterfall([
        callback => s3.putBucketVersioning({
            Bucket: bucket,
            VersioningConfiguration: versioningEnabled,
        }, err => callback(err)),

238

0

89

README_ja.md?plain=1

GitHub: applideveloper/neo-async

138
139
140
141
142
143
144
145
146
147
        next(null, total + n);
    };
});
var funcs = {
    'async': function(callback) {
        async.waterfall(tasks, callback);
    },
    'neo-async': function(callback) {
        neo_async.waterfall(tasks, callback);
    }

45

0

0

+ 9 other calls in file

check.js

GitHub: Souler/I-Wanna-Watch

94
95
96
97
98
99
100
101
102
103
                });
        };

        asyncFns.push(filesFilter);

        return async.waterfall(asyncFns, cb);
}

// The script is being run directly
if (!module.parent)

0

3

2

Discogs.js

GitHub: StephenGregory/google-music-desktop-wallpapers

124
125
126
127
128
129
130
131
132
133
});

const primaryImageReleaseImageFunc = releaseIds.map(id => createFunctionToGetImageFromReleaseDetails(id, imageCoverPaths));
const getDigitalImageFunctions = imageCoverPaths.concat(primaryImageReleaseImageFunc).map((fn) => {
    return (cb) => {
        async.waterfall([fn,
            function validate(imageUrl, cb) {
                db.getImage(imageUrl, (error, content) => {
                    if (error) {
                        return cb(error);

0

2

1

objectPutCopyPart.js

GitHub: scality/cloudserver

87
88
89
90
91
92
93
94
95
96
    objectKey: destObjectKey,
    partNumber: paddedPartNumber,
    uploadId,
};

return async.waterfall([
    function checkDestAuth(next) {
        return metadataValidateBucketAndObj(valPutParams, log,
            (err, destBucketMD) => {
                if (err) {

238

0

89

+ 5 other calls in file

webxr_routes.js

GitHub: polytropoi/ServiceMedia

410
411
412
413
414
415
416
417
418
419
    console.log("1 error getting scene data: " + err);
    res.end();
} else { 
    let accessScene = true;
    // sceneData = sceneData;
    // async.waterfall([ 
    // function (callback) {
    //     //TODO use sceneNetworkSettings or whatever
    //     socketScripts = "<script src=\x22/connect/connect.js\x22 defer=\x22defer\x22></script>" +
    //     "<script src=\x22//ajax.googleapis.com/ajax/libs/jquery/1.8.3/jquery.min.js\x22></script>" +

1

3

2

jquery.reading-helper.js

GitHub: megumiimai/jquery-kanji-reading-helper

956
957
958
959
960
961
962
963
964
965
* @returns {AsyncFunction} An asynchronous wrapper of the `func`. To be
* invoked with `(args..., callback)`.
* @example
*
* // passing a regular synchronous function
* async.waterfall([
*     async.apply(fs.readFile, filename, "utf8"),
*     async.asyncify(JSON.parse),
*     function (data, next) {
*         // data is the result of parsing the text.

0

2

1

+ 11 other calls in file

index.js

GitHub: artilleryio/artillery

127
128
129
130
131
132
133
134
135
136
  return next(null, initialContext);
};

let steps = [init].concat(tasks);

A.waterfall(
  steps,
  function done(err, context) {
    if (err) {
      debug(err);

436

0

59

ngsiUtils.js

GitHub: telefonicaid/iotagent-node-lib

200
201
202
203
204
205
206
207
208
209
210
211
        const middlewareList = _.clone(middlewareCollection);


        middlewareList.unshift(emptyMiddleware);
        middlewareList.push(endMiddleware);


        async.waterfall(middlewareList, callback);
    } else {
        callback(null, entity);
    }
}

74

56

23

+ 3 other calls in file

routeBackbeat.js

GitHub: scality/cloudserver

1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
        query: request.query,
    });
    return responseJSONBody(errors.MethodNotAllowed, null, response, log);
}

return async.waterfall([next => auth.server.doAuth(
    request, log, (err, userInfo) => {
        if (err) {
            log.debug('authentication error', {
                error: err,

236

0

89

order_module.js

GitHub: MuYiez/baolong-node-test

18
19
20
21
22
23
24
25
26
27
shop_info.forEach(element => {
    task.push((cb) => {
        getOrder(element, cb)
    })
});
async.waterfall(task, function (err, result) {
    if (err) {
        console.log(err);
    }
    console.log("订单同步完成！")

0

0

1