error aggregation

1 files changed, 2 insertions, 0 deletions

diff --git a/worker.go b/worker.go
index d1612edd..c52960b2 100644
--- a/worker.go
+++ b/worker.go
@@ -211,6 +211,8 @@ func (w *Worker) start() error {
 			if w.rl != nil {
 				w.rl.Close()
 			}
+
+			w.err.Close()
 		}
 	}()