From 730c76737a64c798b37adefb15ea0f223361631b Mon Sep 17 00:00:00 2001 From: Wolfy-J Date: Sun, 28 Jan 2018 18:58:06 +0300 Subject: Context --- pool.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'pool.go') diff --git a/pool.go b/pool.go index deb24fd7..dfa7ab1b 100644 --- a/pool.go +++ b/pool.go @@ -26,8 +26,8 @@ const ( // Pool controls worker creation, destruction and task routing. type Pool struct { - // EventHandler is optional callback to handle worker create/destruct/error events. - EventHandler func(event int, w *Worker, ctx interface{}) + // Observer is optional callback to handle worker create/destruct/error events. + Observer func(event int, w *Worker, ctx interface{}) // pool behaviour cfg Config @@ -236,7 +236,7 @@ func (p *Pool) createWorker() (*Worker, error) { // throw invokes event handler if any. func (p *Pool) throw(event int, w *Worker, ctx interface{}) { - if p.EventHandler != nil { - p.EventHandler(event, w, ctx) + if p.Observer != nil { + p.Observer(event, w, ctx) } } -- cgit v1.2.3