Adds WithDeferred, which allows the caller to run an arbitrary function at the end of each goroutine in a pipeline stage. One use of this is to ensure panicking goroutines can be effectively managed.
Also fixes a bug where channels on a worker pool were being closed way too late due to an extra defer. Oops.
Adds
WithDeferred, which allows the caller to run an arbitrary function at the end of each goroutine in a pipeline stage. One use of this is to ensure panicking goroutines can be effectively managed.Also fixes a bug where channels on a worker pool were being closed way too late due to an extra
defer. Oops.