When the stream is /dev/null then there is a case for prematurely shutting down all worker nodes since they will not be required.
As the code currently stands, this case is ignored and so the workers all remain running, which hangs the process.
Since this code is likely to be removed this year I didn't invest any time in refactoring the synchronous assignment of $this.pipService, instead I simply exposed an interface that can enumerate the workers and kill them.
bugfix for issue highlighted in https://github.com/pelias/polylines/issues/245
When the stream is
/dev/null
then there is a case for prematurely shutting down all worker nodes since they will not be required. As the code currently stands, this case is ignored and so the workers all remain running, which hangs the process.Since this code is likely to be removed this year I didn't invest any time in refactoring the synchronous assignment of
$this.pipService
, instead I simply exposed an interface that can enumerate the workers and kill them.