Method getContent

src/Pipe.js:474–484

* Returns content of given bucket. * @param {number} [bucket=0] Bucket index * @param {boolean} [waitForCompletion=true] If set to true, the value is * being resolved after all pipe tasks have been completed. * @throws {Error} If bucket index is out of bounds. * @return {Chain|Promise

(bucket = 0, waitForCompletion = true)

   * @return {Chain|Promise} content
   */
  getContent (bucket = 0, waitForCompletion = true) {
    if (bucket >= this._bucketContent.length) {
      throw new Error(`Bucket index ${bucket} is out of bounds.`)
    }
    if (waitForCompletion && this.isBusy()) {
      return new Promise((resolve, reject) => {
        this._bucketListeners[bucket].push({ resolve, reject })
      })
    }
    return this._bucketContent[bucket]
  }

  /**
   * Sets content of given bucket and propagates it through the pipe.