diff options
| -rw-r--r-- | pool.go | 8 | ||||
| -rw-r--r-- | pool_test.go | 4 |
2 files changed, 6 insertions, 6 deletions
@@ -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) } } diff --git a/pool_test.go b/pool_test.go index db38cbc4..bada2fe8 100644 --- a/pool_test.go +++ b/pool_test.go @@ -149,8 +149,8 @@ func Test_Pool_Broken_Replace(t *testing.T) { assert.NotNil(t, p) assert.NoError(t, err) - - p.EventHandler = func(e int, w *Worker, ctx interface{}) { + + p.Observer = func(e int, w *Worker, ctx interface{}) { if err, ok := ctx.(error); ok { assert.Contains(t, err.Error(), "undefined_function()") } |