additional event

2 files changed, 4 insertions, 0 deletions

diff --git a/pool.go b/pool.go
index 121967c5..30c30dfa 100644
--- a/pool.go
+++ b/pool.go
@@ -13,6 +13,9 @@ const (
 	// EventWorkerError thrown any worker related even happen (passed with WorkerError)
 	EventWorkerError
 
+	// EventWorkerDead thrown when worker stops worker for any reason.
+	EventWorkerDead
+
 	// EventPoolError caused on pool wide errors
 	EventPoolError
 )
diff --git a/static_pool.go b/static_pool.go
index df20ad20..9449ea0c 100644
--- a/static_pool.go
+++ b/static_pool.go
@@ -239,6 +239,7 @@ func (p *StaticPool) destroyWorker(w *Worker, caused interface{}) {
 // watchWorker watches worker state and replaces it if worker fails.
 func (p *StaticPool) watchWorker(w *Worker) {
 	err := w.Wait()
+	p.throw(EventWorkerDead, w)
 
 	// detaching
 	p.muw.Lock()