diff options
author | Wolfy-J <[email protected]> | 2018-05-29 13:03:34 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-05-29 13:03:34 +0300 |
commit | b8bc792b263a3891e125757a35cc563bb85f1a0b (patch) | |
tree | f7a9e6f2568220491a26f6544e4acf0ed62012bb /pool.go | |
parent | 50f820833eeef8518b3b978b33c6f20391225162 (diff) |
nested observers
Diffstat (limited to 'pool.go')
-rw-r--r-- | pool.go | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -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) |