pl(streams, (err, value) => {
      if (err)
        reject(err);
      else
        resolve(value);
    }, { signal, end });
  });
}
$ = {
  finished,
  pipeline
};
return $})