tunnckoCore/async-control

View on GitHub
README.md

Summary

Maintainability
Test Coverage
# [async-control][author-www-url] [![npmjs.com][npmjs-img]][npmjs-url] [![The MIT License][license-img]][license-url] 

> Ultimate asynchronous control flow goodness with built-in hook system and compose, series, define and parallel methods. Uses async.map and async.mapSeries methods. Allows passing custom iterator function.

[![code climate][codeclimate-img]][codeclimate-url] [![standard code style][standard-img]][standard-url] [![travis build status][travis-img]][travis-url] [![coverage status][coveralls-img]][coveralls-url] [![dependency status][david-img]][david-url]

## Install
```
npm i async-control --save
```

## Usage
> For more use-cases see the [tests](./test.js)

```js
const fs = require('fs')
const asyncControl = require('async-control')

asyncControl.series([
  function one (next) {
    console.log('first')
    fs.readFile('package.json', 'utf8', next)
  },
  function two (next) {
    setTimeout(function () {
      console.log('second')
      fs.stat('not exist', next)
    }, 100)
  },
  function three (next) {
    console.log('third')
    next(null, 123)
  }
], {settle: false}, function done (err, res) {
  // => first
  // => second
  // => third

  console.log('err:', err)
  // => if `options.settle` is true - `undefined`, otherwise thrown Error
  console.log('res:', res) // => array of results
  // => res[0] is content of package.json file
  // => res[1] is `undefined`, because second function throws Error (ENOENT)
  // if `options.settle` is true
  // - res[1] will be Error
  // - res[2] will be 123
})
```

### [AsyncControl](index.js#L24)

> Initialize `AsyncControl` with `options` to
control enabling/disabling `options.settle`, passing
custom `iterator` and pass different hooks - before, after, etc.

**Params**

* `options` **{Object=}**    

### [.series](index.js#L76)
> Iterate over `value` in series flow. The `async.mapSeries` method is used.

**Params**

* `value` **{Object|Array|Function}**: The value to iterate over.    
* `options` **{Object=}**: Can pass different hooks - before, after, beforeEach, afterEach.    
* `done` **{Function=}**: If not passed, thunk is returned (function that accepts callback).    
* `returns` **{Function}**: Or `undefined` if `done` is passed.  

**Example**

```js
var fs = require('fs')
var asyncControl = require('async-control')

asyncControl.series([
  function one (cb) {
    cb(null, 'foo')
  },
  function two (cb) {
    fs.readFile('not exist', cb)
  },
  function three (cb) {
    cb(null, 'bar')
  }
], console.log) //=> ENOENT Error, ['foo', undefined]
```

### [.parallel](index.js#L126)
> Iterate over `value` in parallel flow. The `async.map` method is used.

**Params**

* `value` **{Object|Array|Function}**: The value to iterate over.    
* `options` **{Object=}**: Can pass different hooks - before, after, beforeEach, afterEach.    
* `done` **{Function=}**: If not passed, thunk is returned (function that accepts callback).    
* `returns` **{Function}**: Or `undefined` if `done` is passed.  

**Example**

```js
var fs = require('fs')
var asyncControl = require('async-control')

asyncControl.parallel([
  function one (next) {
    setTimeout(function () {
      console.log('first')
      next(null, 100)
    }, Math.random() * 50)
  },
  function two (next) {
    setTimeout(function () {
      console.log('second')
      next(null, 700)
    }, Math.random() * 200)
  },
  function three (next) {
    setTimeout(function () {
      console.log('third')
      next(null, 2000)
    }, 0)
  }
], function done (err, res) {
  // => third
  // => first
  // => second

  console.log(err) // => null
  console.log(res) // => [2000, 100, 700]
})
```

### [.compose](index.js#L164)
> Compose `series` or `parallel` method. Can be used to create `settleSeries` or `settleParallel` methods for example.

**Params**

* `flow` **{String}**: Type of flow, one of `'series'` or `'parallel'`.    
* `options` **{Object=}**: Can pass different hooks - before, after, beforeEach, afterEach.    
* `returns` **{Function}**: Composed `series` or `parallel` method, depends on `flow`.  

**Example**

```js
var fs = require('fs')
var asyncControl = require('async-control')

// the internal `.series` method is created this way - using `.compose`
var series = asyncControl.compose('series')
series([
  function one (cb) {
    cb(null, 123)
  },
  function two (cb) {
    fs.readFile('not exist', cb)
  },
  function three (cb) {
    cb(null, 456)
  }
], {settle: true}, console.log) //=> null, [123, ENOENT Error, 456]
```

### Custom iterator
> Below example shows how to create your own iterator using `asyncControl.define` method. This also can be done by passing function to `options.iterator`. It recieves `app` and `options` and must return function which is directly passed to `async.map` and/or `async.mapSeries` methods. 

**Params**

* `app` **{Object}**: instance of AsyncControl    
* `opts` **{Object}**: the `app` options    
* `returns` **{Function}**: iterator passed directly to [async.map / async.mapSeries](http://j.mp/1QyzUe9)

**Example**

```js
const util = require('util')
const asyncControl = require('async-control')

asyncControl.define('iterator', function customIterator (app, options) {
  // this === app
  return iterator (fn, next) {
    // this === app
    console.log(util.inspect(fn))
    next()
  }
})
asyncControl.series([
  function first (next) { next(null, 1) },
  function second (next) { next(null, 2) },
  function third (next) { next(null, 3) }
], function (err, res) {
  // => [Function: first]
  // => [Function: second]
  // => [Function: third]

  console.log(err, res)
  // => null, [1, 2, 3]
})
```

## Contributing
Pull requests and stars are always welcome. For bugs and feature requests, [please create an issue](https://github.com/tunnckoCore/async-control/issues/new).  
But before doing anything, please read the [CONTRIBUTING.md](./CONTRIBUTING.md) guidelines.

## [Charlike Make Reagent](http://j.mp/1stW47C) [![new message to charlike][new-message-img]][new-message-url] [![freenode #charlike][freenode-img]][freenode-url]

[![tunnckoCore.tk][author-www-img]][author-www-url] [![keybase tunnckoCore][keybase-img]][keybase-url] [![tunnckoCore npm][author-npm-img]][author-npm-url] [![tunnckoCore twitter][author-twitter-img]][author-twitter-url] [![tunnckoCore github][author-github-img]][author-github-url]

[async]: https://github.com/caolan/async
[extend-shallow]: https://github.com/jonschlinkert/extend-shallow
[lazy-cache]: https://github.com/jonschlinkert/lazy-cache

[npmjs-url]: https://www.npmjs.com/package/async-control
[npmjs-img]: https://img.shields.io/npm/v/async-control.svg?label=async-control

[license-url]: https://github.com/tunnckoCore/async-control/blob/master/LICENSE
[license-img]: https://img.shields.io/badge/license-MIT-blue.svg

[codeclimate-url]: https://codeclimate.com/github/tunnckoCore/async-control
[codeclimate-img]: https://img.shields.io/codeclimate/github/tunnckoCore/async-control.svg

[travis-url]: https://travis-ci.org/tunnckoCore/async-control
[travis-img]: https://img.shields.io/travis/tunnckoCore/async-control/master.svg

[coveralls-url]: https://coveralls.io/r/tunnckoCore/async-control
[coveralls-img]: https://img.shields.io/coveralls/tunnckoCore/async-control.svg

[david-url]: https://david-dm.org/tunnckoCore/async-control
[david-img]: https://img.shields.io/david/tunnckoCore/async-control.svg

[standard-url]: https://github.com/feross/standard
[standard-img]: https://img.shields.io/badge/code%20style-standard-brightgreen.svg

[author-www-url]: http://www.tunnckocore.tk
[author-www-img]: https://img.shields.io/badge/www-tunnckocore.tk-fe7d37.svg

[keybase-url]: https://keybase.io/tunnckocore
[keybase-img]: https://img.shields.io/badge/keybase-tunnckocore-8a7967.svg

[author-npm-url]: https://www.npmjs.com/~tunnckocore
[author-npm-img]: https://img.shields.io/badge/npm-~tunnckocore-cb3837.svg

[author-twitter-url]: https://twitter.com/tunnckoCore
[author-twitter-img]: https://img.shields.io/badge/twitter-@tunnckoCore-55acee.svg

[author-github-url]: https://github.com/tunnckoCore
[author-github-img]: https://img.shields.io/badge/github-@tunnckoCore-4183c4.svg

[freenode-url]: http://webchat.freenode.net/?channels=charlike
[freenode-img]: https://img.shields.io/badge/freenode-%23charlike-5654a4.svg

[new-message-url]: https://github.com/tunnckoCore/ama
[new-message-img]: https://img.shields.io/badge/ask%20me-anything-green.svg