Control Flow

Methods

(static) applyEach(fns, …argsopt, callbackopt) → {function}

import applyEach from 'async/applyEach';

Parameters:

Returns:

Type

function

Example

async.applyEach([enableSearch, updateSchema], 'bucket', callback);

// partial application example:
async.each(
    buckets,
    async.applyEach([enableSearch, updateSchema]),
    callback
);

Source:

• applyEach.js, line 4

(static) applyEachSeries(fns, …argsopt, callbackopt) → {function}

import applyEachSeries from 'async/applyEachSeries';

Parameters:

Returns:

Type

function

Source:

• applyEachSeries.js, line 4

See:

• async.applyEach

(static) auto(tasks, concurrencyopt, callbackopt)

import auto from 'async/auto';

Parameters:

Returns:

Example

async.auto({
    // this function will just be passed a callback
    readData: async.apply(fs.readFile, 'data.txt', 'utf-8'),
    showData: ['readData', function(results, cb) {
        // results.readData is the file's contents
        // ...
    }]
}, callback);

async.auto({
    get_data: function(callback) {
        console.log('in get_data');
        // async code to get some data
        callback(null, 'data', 'converted to array');
    },
    make_folder: function(callback) {
        console.log('in make_folder');
        // async code to create a directory to store a file in
        // this is run at the same time as getting the data
        callback(null, 'folder');
    },
    write_file: ['get_data', 'make_folder', function(results, callback) {
        console.log('in write_file', JSON.stringify(results));
        // once there is some data and the directory exists,
        // write the data to a file in the directory
        callback(null, 'filename');
    }],
    email_link: ['write_file', function(results, callback) {
        console.log('in email_link', JSON.stringify(results));
        // once the file is written let's email a link to it...
        // results.write_file contains the filename returned by write_file.
        callback(null, {'file':results.write_file, 'email':'user@example.com'});
    }]
}, function(err, results) {
    console.log('err = ', err);
    console.log('results = ', results);
});

Source:

• auto.js, line 13

(static) autoInject(tasks, callbackopt)

import autoInject from 'async/autoInject';

Parameters:

Example

//  The example from `auto` can be rewritten as follows:
async.autoInject({
    get_data: function(callback) {
        // async code to get some data
        callback(null, 'data', 'converted to array');
    },
    make_folder: function(callback) {
        // async code to create a directory to store a file in
        // this is run at the same time as getting the data
        callback(null, 'folder');
    },
    write_file: function(get_data, make_folder, callback) {
        // once there is some data and the directory exists,
        // write the data to a file in the directory
        callback(null, 'filename');
    },
    email_link: function(write_file, callback) {
        // once the file is written let's email a link to it...
        // write_file contains the filename returned by write_file.
        callback(null, {'file':write_file, 'email':'user@example.com'});
    }
}, function(err, results) {
    console.log('err = ', err);
    console.log('email_link = ', results.email_link);
});

// If you are using a JS minifier that mangles parameter names, `autoInject`
// will not work with plain functions, since the parameter names will be
// collapsed to a single letter identifier.  To work around this, you can
// explicitly specify the names of the parameters your task function needs
// in an array, similar to Angular.js dependency injection.

// This still has an advantage over plain `auto`, since the results a task
// depends on are still spread into arguments.
async.autoInject({
    //...
    write_file: ['get_data', 'make_folder', function(get_data, make_folder, callback) {
        callback(null, 'filename');
    }],
    email_link: ['write_file', function(write_file, callback) {
        callback(null, {'file':write_file, 'email':'user@example.com'});
    }]
    //...
}, function(err, results) {
    console.log('err = ', err);
    console.log('email_link = ', results.email_link);
});

Source:

• autoInject.js, line 24

See:

• async.auto

(static) cargo(worker, payloadopt) → {CargoObject}

import cargo from 'async/cargo';

Parameters:

Returns:

Type

CargoObject

Example

// create a cargo object with payload 2
var cargo = async.cargo(function(tasks, callback) {
    for (var i=0; i<tasks.length; i++) {
        console.log('hello ' + tasks[i].name);
    }
    callback();
}, 2);

// add some items
cargo.push({name: 'foo'}, function(err) {
    console.log('finished processing foo');
});
cargo.push({name: 'bar'}, function(err) {
    console.log('finished processing bar');
});
cargo.push({name: 'baz'}, function(err) {
    console.log('finished processing baz');
});

Source:

• cargo.js, line 33

See:

• async.queue

(static) compose(…functions) → {function}

import compose from 'async/compose';

Parameters:

Returns:

Type

function

Example

function add1(n, callback) {
    setTimeout(function () {
        callback(null, n + 1);
    }, 10);
}

function mul3(n, callback) {
    setTimeout(function () {
        callback(null, n * 3);
    }, 10);
}

var add1mul3 = async.compose(mul3, add1);
add1mul3(4, function (err, result) {
    // result now equals 15
});

Source:

• compose.js, line 4

(static) doDuring(fn, test, callbackopt)

import doDuring from 'async/doDuring';

Parameters:

Source:

• doDuring.js, line 6

See:

• async.during

(static) doUntil(iteratee, test, callbackopt)

import doUntil from 'async/doUntil';

Parameters:

Source:

• doUntil.js, line 3

See:

• async.doWhilst

(static) doWhilst(iteratee, test, callbackopt)

import doWhilst from 'async/doWhilst';

Parameters:

Source:

• doWhilst.js, line 7

See:

• async.whilst

(static) during(test, fn, callbackopt)

import during from 'async/during';

Parameters:

Example

var count = 0;

async.during(
    function (callback) {
        return callback(null, count < 5);
    },
    function (callback) {
        count++;
        setTimeout(callback, 1000);
    },
    function (err) {
        // 5 seconds have passed
    }
);

Source:

• during.js, line 5

See:

• async.whilst

(static) forever(fn, errbackopt)

import forever from 'async/forever';

Parameters:

Example

async.forever(
    function(next) {
        // next is suitable for passing to things that need a callback(err [, whatever]);
        // it will result in this function being called again.
    },
    function(err) {
        // if next is called with a value in its first parameter, it will appear
        // in here as 'err', and execution will stop.
    }
);

Source:

• forever.js, line 7

(static) parallel(tasks, callbackopt)

import parallel from 'async/parallel';

Parameters:

Example

async.parallel([
    function(callback) {
        setTimeout(function() {
            callback(null, 'one');
        }, 200);
    },
    function(callback) {
        setTimeout(function() {
            callback(null, 'two');
        }, 100);
    }
],
// optional callback
function(err, results) {
    // the results array will equal ['one','two'] even though
    // the second function had a shorter timeout.
});

// an example using an object instead of an array
async.parallel({
    one: function(callback) {
        setTimeout(function() {
            callback(null, 1);
        }, 200);
    },
    two: function(callback) {
        setTimeout(function() {
            callback(null, 2);
        }, 100);
    }
}, function(err, results) {
    // results is now equals to: {one: 1, two: 2}
});

Source:

• parallel.js, line 4

(static) parallelLimit(tasks, limit, callbackopt)

import parallelLimit from 'async/parallelLimit';

Parameters:

Source:

• parallelLimit.js, line 4

See:

• async.parallel

(static) priorityQueue(worker, concurrency) → {QueueObject}

import priorityQueue from 'async/priorityQueue';

Parameters:

Returns:

Type

QueueObject

Source:

• priorityQueue.js, line 8

See:

• async.queue

(static) queue(worker, concurrencyopt) → {QueueObject}

import queue from 'async/queue';

Parameters:

Returns:

Type

QueueObject

Example

// create a queue object with concurrency 2
var q = async.queue(function(task, callback) {
    console.log('hello ' + task.name);
    callback();
}, 2);

// assign a callback
q.drain = function() {
    console.log('all items have been processed');
};

// add some items to the queue
q.push({name: 'foo'}, function(err) {
    console.log('finished processing foo');
});
q.push({name: 'bar'}, function (err) {
    console.log('finished processing bar');
});

// add some items to the queue (batch-wise)
q.push([{name: 'baz'},{name: 'bay'},{name: 'bax'}], function(err) {
    console.log('finished processing item');
});

// add some items to the front of the queue
q.unshift({name: 'bar'}, function (err) {
    console.log('finished processing bar');
});

Source:

• queue.js, line 58

(static) race(tasks, callback)

import race from 'async/race';

Parameters:

Returns:

Example

async.race([
    function(callback) {
        setTimeout(function() {
            callback(null, 'one');
        }, 200);
    },
    function(callback) {
        setTimeout(function() {
            callback(null, 'two');
        }, 100);
    }
],
// main callback
function(err, result) {
    // the result will be equal to 'two' as it finishes earlier
});

Source:

• race.js, line 6

(static) retry(optsopt, task, callbackopt)

import retry from 'async/retry';

Parameters:

Example

// The `retry` function can be used as a stand-alone control flow by passing
// a callback, as shown below:

// try calling apiMethod 3 times
async.retry(3, apiMethod, function(err, result) {
    // do something with the result
});

// try calling apiMethod 3 times, waiting 200 ms between each retry
async.retry({times: 3, interval: 200}, apiMethod, function(err, result) {
    // do something with the result
});

// try calling apiMethod 10 times with exponential backoff
// (i.e. intervals of 100, 200, 400, 800, 1600, ... milliseconds)
async.retry({
  times: 10,
  interval: function(retryCount) {
    return 50 * Math.pow(2, retryCount);
  }
}, apiMethod, function(err, result) {
    // do something with the result
});

// try calling apiMethod the default 5 times no delay between each retry
async.retry(apiMethod, function(err, result) {
    // do something with the result
});

// try calling apiMethod only when error condition satisfies, all other
// errors will abort the retry control flow and return to final callback
async.retry({
  errorFilter: function(err) {
    return err.message === 'Temporary error'; // only retry on a specific error
  }
}, apiMethod, function(err, result) {
    // do something with the result
});

// to retry individual methods that are not as reliable within other
// control flow functions, use the `retryable` wrapper:
async.auto({
    users: api.getUsers.bind(api),
    payments: async.retryable(3, api.getPayments.bind(api))
}, function(err, results) {
    // do something with the results
});

Source:

• retry.js, line 5

See:

• async.retryable

(static) retryable(optsopt, task) → {AsyncFunction}

import retryable from 'async/retryable';

Parameters:

Returns:

Type

AsyncFunction

Example

async.auto({
    dep1: async.retryable(3, getFromFlakyService),
    process: ["dep1", async.retryable(3, function (results, cb) {
        maybeProcessData(results.dep1, cb);
    })]
}, callback);

Source:

• retryable.js, line 5

See:

• async.retry

(static) seq(…functions) → {function}

import seq from 'async/seq';

Parameters:

Returns:

Type

function

Example

// Requires lodash (or underscore), express3 and dresende's orm2.
// Part of an app, that fetches cats of the logged user.
// This example uses `seq` function to avoid overnesting and error
// handling clutter.
app.get('/cats', function(request, response) {
    var User = request.models.User;
    async.seq(
        _.bind(User.get, User),  // 'User.get' has signature (id, callback(err, data))
        function(user, fn) {
            user.getCats(fn);      // 'getCats' has signature (callback(err, data))
        }
    )(req.session.user_id, function (err, cats) {
        if (err) {
            console.error(err);
            response.json({ status: 'error', message: err.message });
        } else {
            response.json({ status: 'ok', message: 'Cats found', data: cats });
        }
    });
});

Source:

• seq.js, line 7

See:

• async.compose

(static) series(tasks, callbackopt)

import series from 'async/series';

Parameters:

Example

async.series([
    function(callback) {
        // do some stuff ...
        callback(null, 'one');
    },
    function(callback) {
        // do some more stuff ...
        callback(null, 'two');
    }
],
// optional callback
function(err, results) {
    // results is now equal to ['one', 'two']
});

async.series({
    one: function(callback) {
        setTimeout(function() {
            callback(null, 1);
        }, 200);
    },
    two: function(callback){
        setTimeout(function() {
            callback(null, 2);
        }, 100);
    }
}, function(err, results) {
    // results is now equal to: {one: 1, two: 2}
});

Source:

• series.js, line 4

(static) times(n, iteratee, callback)

import times from 'async/times';

Parameters:

Example

// Pretend this is some complicated async factory
var createUser = function(id, callback) {
    callback(null, {
        id: 'user' + id
    });
};

// generate 5 users
async.times(5, function(n, next) {
    createUser(n, function(err, user) {
        next(err, user);
    });
}, function(err, users) {
    // we should now have 5 users
});

Source:

• times.js, line 4

See:

• async.map

(static) timesLimit(count, limit, iteratee, callback)

import timesLimit from 'async/timesLimit';

Parameters:

Source:

• timesLimit.js, line 5

See:

• async.times

(static) timesSeries(n, iteratee, callback)

import timesSeries from 'async/timesSeries';

Parameters:

Source:

• timesSeries.js, line 4

See:

• async.times

(static) tryEach(tasks, callbackopt)

import tryEach from 'async/tryEach';

Parameters:

Example

async.tryEach([
    function getDataFromFirstWebsite(callback) {
        // Try getting the data from the first website
        callback(err, data);
    },
    function getDataFromSecondWebsite(callback) {
        // First website failed,
        // Try getting the data from the backup website
        callback(err, data);
    }
],
// optional callback
function(err, results) {
    Now do something with the data.
});

Source:

• tryEach.js, line 6

(static) until(test, iteratee, callbackopt)

import until from 'async/until';

Parameters:

Source:

• until.js, line 3

See:

• async.whilst

(static) waterfall(tasks, callbackopt)

import waterfall from 'async/waterfall';

Parameters:

Returns:

Example

async.waterfall([
    function(callback) {
        callback(null, 'one', 'two');
    },
    function(arg1, arg2, callback) {
        // arg1 now equals 'one' and arg2 now equals 'two'
        callback(null, 'three');
    },
    function(arg1, callback) {
        // arg1 now equals 'three'
        callback(null, 'done');
    }
], function (err, result) {
    // result now equals 'done'
});

// Or, with named functions:
async.waterfall([
    myFirstFunction,
    mySecondFunction,
    myLastFunction,
], function (err, result) {
    // result now equals 'done'
});
function myFirstFunction(callback) {
    callback(null, 'one', 'two');
}
function mySecondFunction(arg1, arg2, callback) {
    // arg1 now equals 'one' and arg2 now equals 'two'
    callback(null, 'three');
}
function myLastFunction(arg1, callback) {
    // arg1 now equals 'three'
    callback(null, 'done');
}

Source:

• waterfall.js, line 9

(static) whilst(test, iteratee, callbackopt)

import whilst from 'async/whilst';

Parameters:

Returns:

Example

var count = 0;
async.whilst(
    function() { return count < 5; },
    function(callback) {
        count++;
        setTimeout(function() {
            callback(null, count);
        }, 1000);
    },
    function (err, n) {
        // 5 seconds have passed, n = 5
    }
);

Source:

• whilst.js, line 7

Type Definitions

CargoObject

import cargo from 'async/cargo';

Type:

• Object

Properties:

Source:

• cargo.js, line 3

QueueObject

import queue from 'async/queue';

Type:

• Object

Properties:

Source:

• queue.js, line 4