1. module es6-promise-pool
   1. function es6-promise-pool (source, concurrency, options)
   2. function es6-promise-pool.PromisePool (source, concurrency, options)
   3. function es6-promise-pool.PromisePoolEvent (target, type, data)
   4. object es6-promise-pool.PromisePool.prototype
2. module es6-promise-pool.PromisePool
   1. function es6-promise-pool.PromisePool (source, concurrency, options)
   2. function es6-promise-pool.PromisePool.PromisePoolEvent (target, type, data)
3. module es6-promise-pool.PromisePool.prototype
   1. function es6-promise-pool.PromisePool.prototype._fireEvent (type, data)
   2. function es6-promise-pool.PromisePool.prototype._onPooledPromiseFulfilled (promise, result)
   3. function es6-promise-pool.PromisePool.prototype._onPooledPromiseRejected (promise, error)
   4. function es6-promise-pool.PromisePool.prototype._proceed ()
   5. function es6-promise-pool.PromisePool.prototype._settle (error)
   6. function es6-promise-pool.PromisePool.prototype._trackPromise (promise)
   7. function es6-promise-pool.PromisePool.prototype.active ()
   8. function es6-promise-pool.PromisePool.prototype.concurrency (value)
   9. function es6-promise-pool.PromisePool.prototype.constructor (source, concurrency, options)
   10. function es6-promise-pool.PromisePool.prototype.promise ()
   11. function es6-promise-pool.PromisePool.prototype.size ()
   12. function es6-promise-pool.PromisePool.prototype.start ()
   13. object es6-promise-pool.PromisePool.prototype._listeners

module es6-promise-pool

function es6-promise-pool (source, concurrency, options)

• description and source-code

  es6-promise-pool = function (source, concurrency, options) {
    EventTarget.call(this)
    if (typeof concurrency !== 'number' ||
        Math.floor(concurrency) !== concurrency ||
        concurrency < 1) {
      throw new Error('Invalid concurrency')
    }
    this._concurrency = concurrency
    this._options = options || {}
    this._options.promise = this._options.promise || Promise
    this._iterator = toIterator(source, this._options.promise)
    this._done = false
    this._size = 0
    this._promise = null
    this._callbacks = null
  }

• example usage

  n/a

function es6-promise-pool.PromisePool (source, concurrency, options)

• description and source-code

  PromisePool = function (source, concurrency, options) {
    EventTarget.call(this)
    if (typeof concurrency !== 'number' ||
        Math.floor(concurrency) !== concurrency ||
        concurrency < 1) {
      throw new Error('Invalid concurrency')
    }
    this._concurrency = concurrency
    this._options = options || {}
    this._options.promise = this._options.promise || Promise
    this._iterator = toIterator(source, this._options.promise)
    this._done = false
    this._size = 0
    this._promise = null
    this._callbacks = null
  }

• example usage

  n/a

function es6-promise-pool.PromisePoolEvent (target, type, data)

• description and source-code

  PromisePoolEvent = function (target, type, data) {
    this.target = target
    this.type = type
    this.data = data
  }

• example usage

  n/a

module es6-promise-pool.PromisePool

function es6-promise-pool.PromisePool (source, concurrency, options)

• description and source-code

  PromisePool = function (source, concurrency, options) {
    EventTarget.call(this)
    if (typeof concurrency !== 'number' ||
        Math.floor(concurrency) !== concurrency ||
        concurrency < 1) {
      throw new Error('Invalid concurrency')
    }
    this._concurrency = concurrency
    this._options = options || {}
    this._options.promise = this._options.promise || Promise
    this._iterator = toIterator(source, this._options.promise)
    this._done = false
    this._size = 0
    this._promise = null
    this._callbacks = null
  }

• example usage

  n/a

function es6-promise-pool.PromisePool.PromisePoolEvent (target, type, data)

• description and source-code

  PromisePoolEvent = function (target, type, data) {
    this.target = target
    this.type = type
    this.data = data
  }

• example usage

  n/a

module es6-promise-pool.PromisePool.prototype

function es6-promise-pool.PromisePool.prototype._fireEvent (type, data)

• description and source-code

  _fireEvent = function (type, data) {
    this.dispatchEvent(new PromisePoolEvent(this, type, data))
  }

• example usage

  ...
    this._promise = null
    this._callbacks = null
  }
  
  PromisePool.prototype._onPooledPromiseFulfilled = function (promise, result) {
    this._size--
    if (this.active()) {
      this._fireEvent('fulfilled', {
        promise: promise,
        result: result
      })
      this._proceed()
    }
  }
  ...

function es6-promise-pool.PromisePool.prototype._onPooledPromiseFulfilled (promise, result)

• description and source-code

  _onPooledPromiseFulfilled = function (promise, result) {
    this._size--
    if (this.active()) {
      this._fireEvent('fulfilled', {
        promise: promise,
        result: result
      })
      this._proceed()
    }
  }

• example usage

  ...
    }
  }
  
  PromisePool.prototype._trackPromise = function (promise) {
    var that = this
    promise
      .then(function (result) {
        that._onPooledPromiseFulfilled(promise, result)
      }, function (error) {
        that._onPooledPromiseRejected(promise, error)
      })['catch'](function (err) {
        that._settle(new Error('Promise processing failed: ' + err))
      })
  }
  ...

function es6-promise-pool.PromisePool.prototype._onPooledPromiseRejected (promise, error)

• description and source-code

  _onPooledPromiseRejected = function (promise, error) {
    this._size--
    if (this.active()) {
      this._fireEvent('rejected', {
        promise: promise,
        error: error
      })
      this._settle(error || new Error('Unknown error'))
    }
  }

• example usage

  ...
  
  PromisePool.prototype._trackPromise = function (promise) {
    var that = this
    promise
      .then(function (result) {
        that._onPooledPromiseFulfilled(promise, result)
      }, function (error) {
        that._onPooledPromiseRejected(promise, error)
      })['catch'](function (err) {
        that._settle(new Error('Promise processing failed: ' + err))
      })
  }
  
  PromisePool.prototype._proceed = function () {
    if (!this._done) {
  ...

function es6-promise-pool.PromisePool.prototype._proceed ()

• description and source-code

  _proceed = function () {
    if (!this._done) {
      var result = null
      while (this._size < this._concurrency &&
          !(result = this._iterator.next()).done) {
        this._size++
        this._trackPromise(result.value)
      }
      this._done = (result === null || !!result.done)
    }
    if (this._done && this._size === 0) {
      this._settle()
    }
  }

• example usage

  ...
  PromisePool.prototype = new EventTarget()
  PromisePool.prototype.constructor = PromisePool
  
  PromisePool.prototype.concurrency = function (value) {
    if (typeof value !== 'undefined') {
      this._concurrency = value
      if (this.active()) {
        this._proceed()
      }
    }
    return this._concurrency
  }
  
  PromisePool.prototype.size = function () {
    return this._size
  ...

function es6-promise-pool.PromisePool.prototype._settle (error)

• description and source-code

  _settle = function (error) {
    if (error) {
      this._callbacks.reject(error)
    } else {
      this._callbacks.resolve()
    }
    this._promise = null
    this._callbacks = null
  }

• example usage

  ...
  PromisePool.prototype._onPooledPromiseRejected = function (promise, error) {
    this._size--
    if (this.active()) {
      this._fireEvent('rejected', {
        promise: promise,
        error: error
      })
      this._settle(error || new Error('Unknown error'))
    }
  }
  
  PromisePool.prototype._trackPromise = function (promise) {
    var that = this
    promise
      .then(function (result) {
  ...

function es6-promise-pool.PromisePool.prototype._trackPromise (promise)

• description and source-code

  _trackPromise = function (promise) {
    var that = this
    promise
      .then(function (result) {
        that._onPooledPromiseFulfilled(promise, result)
      }, function (error) {
        that._onPooledPromiseRejected(promise, error)
      })['catch'](function (err) {
        that._settle(new Error('Promise processing failed: ' + err))
      })
  }

• example usage

  ...
  
  PromisePool.prototype._proceed = function () {
    if (!this._done) {
      var result = null
      while (this._size < this._concurrency &&
          !(result = this._iterator.next()).done) {
        this._size++
        this._trackPromise(result.value)
      }
      this._done = (result === null || !!result.done)
    }
    if (this._done && this._size === 0) {
      this._settle()
    }
  }
  ...

function es6-promise-pool.PromisePool.prototype.active ()

• description and source-code

  active = function () {
    return !!this._promise
  }

• example usage

  ...
  }
  PromisePool.prototype = new EventTarget()
  PromisePool.prototype.constructor = PromisePool
  
  PromisePool.prototype.concurrency = function (value) {
    if (typeof value !== 'undefined') {
      this._concurrency = value
      if (this.active()) {
        this._proceed()
      }
    }
    return this._concurrency
  }
  
  PromisePool.prototype.size = function () {
  ...

function es6-promise-pool.PromisePool.prototype.concurrency (value)

• description and source-code

  concurrency = function (value) {
    if (typeof value !== 'undefined') {
      this._concurrency = value
      if (this.active()) {
        this._proceed()
      }
    }
    return this._concurrency
  }

• example usage

  n/a

function es6-promise-pool.PromisePool.prototype.constructor (source, concurrency, options)

• description and source-code

  constructor = function (source, concurrency, options) {
    EventTarget.call(this)
    if (typeof concurrency !== 'number' ||
        Math.floor(concurrency) !== concurrency ||
        concurrency < 1) {
      throw new Error('Invalid concurrency')
    }
    this._concurrency = concurrency
    this._options = options || {}
    this._options.promise = this._options.promise || Promise
    this._iterator = toIterator(source, this._options.promise)
    this._done = false
    this._size = 0
    this._promise = null
    this._callbacks = null
  }

• example usage

  n/a

function es6-promise-pool.PromisePool.prototype.promise ()

• description and source-code

  promise = function () {
    return this._promise
  }

• example usage

  n/a

function es6-promise-pool.PromisePool.prototype.size ()

• description and source-code

  size = function () {
    return this._size
  }

• example usage

  n/a

function es6-promise-pool.PromisePool.prototype.start ()

• description and source-code

  start = function () {
    var that = this
    var Promise = this._options.promise
    this._promise = new Promise(function (resolve, reject) {
      that._callbacks = {
        reject: reject,
        resolve: resolve
      }
      that._proceed()
    })
    return this._promise
  }

• example usage

  ...
  // The number of promises to process simultaneously.
  var concurrency = 3
  
  // Create a pool.
  var pool = new PromisePool(promiseProducer, concurrency)
  
  // Start the pool.
  var poolPromise = pool.start()
  
  // Wait for the pool to settle.
  poolPromise.then(function () {
    console.log('All promises fulfilled')
  }, function (error) {
    console.log('Some promise rejected: ' + error.message)
  })
  ...