Promise.try(() => this._filterCallback(chunk))
      .catch(error => {
        logger.log('error', 'Error in Filter', error)
        return error
      })