From b8bc792b263a3891e125757a35cc563bb85f1a0b Mon Sep 17 00:00:00 2001 From: Wolfy-J Date: Tue, 29 May 2018 13:03:34 +0300 Subject: nested observers --- pool.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'pool.go') diff --git a/pool.go b/pool.go index f8b5f471..a956aabb 100644 --- a/pool.go +++ b/pool.go @@ -13,8 +13,8 @@ const ( // Pool managed set of inner worker processes. type Pool interface { - // Report all caused events to attached watcher. - Report(o func(event int, w *Worker, ctx interface{})) + // Observe all caused events to attached watcher. + Observe(o func(event int, ctx interface{})) // Exec one task with given payload and context, returns result or error. Exec(rqs *Payload) (rsp *Payload, err error) -- cgit v1.2.3