createBuckets () {
    // TODO integrate previous buckets
    // count how many buckets are needed
    let encoderCount = this._bricks.reduce((count, brick) =>
      count + (brick instanceof Encoder ? 1 : 0), 0)

    // create empty buckets
    this._bucketContent =
      new Array(encoderCount + 1).fill().map(() => new Chain())

    return this
  }
/**
   * Creates empty buckets for current bricks.
   * @protected
   * @return {Pipe} Fluent interface
   */
Creates empty buckets for current bricks.
@protected
@return {Pipe} Fluent interface
Creates empty buckets for current bricks . @protected @return { Pipe } Fluent interface
createBuckets () {
    let encoderCount = this._bricks.reduce((count, brick) =>
      count + (brick instanceof Encoder ? 1 : 0), 0)
    this._bucketContent =
      new Array(encoderCount + 1).fill().map(() => new Chain())
    return this
  }
createBuckets ( ) { let encoderCount = this . _bricks . reduce ( ( count , brick ) => count + ( brick instanceof Encoder ? 1 : 0 ) , 0 ) this . _bucketContent = new Array ( encoderCount + 1 ) . fill ( ) . map ( ( ) => new Chain ( ) ) return this }
Creates empty buckets for current bricks.
Creates empty buckets for current bricks .
// TODO integrate previous buckets // count how many buckets are needed // create empty buckets