}, (err, stream) => {
      if (err) {
        throw err;
      }