summaryrefslogtreecommitdiff
path: root/static_pool_test.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-06-10 17:04:02 +0300
committerWolfy-J <[email protected]>2018-06-10 17:04:02 +0300
commit3fe85e9d92f5f98337e8f7fd9a14e6b66b9694bd (patch)
tree2575fbba16df4f95dd392f231ad7d7b30a5dd4ef /static_pool_test.go
parent4c292ee46f5505b00b16186e8f30e9bc1be25895 (diff)
http service
Diffstat (limited to 'static_pool_test.go')
-rw-r--r--static_pool_test.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/static_pool_test.go b/static_pool_test.go
index 97872609..d9fa75cd 100644
--- a/static_pool_test.go
+++ b/static_pool_test.go
@@ -150,7 +150,7 @@ func Test_StaticPool_Broken_Replace(t *testing.T) {
assert.NotNil(t, p)
assert.NoError(t, err)
- p.Observe(func(e int, ctx interface{}) {
+ p.Listen(func(e int, ctx interface{}) {
if err, ok := ctx.(error); ok {
assert.Contains(t, err.Error(), "undefined_function()")
}
@@ -184,7 +184,7 @@ func Test_StaticPool_Broken_FromOutside(t *testing.T) {
assert.Equal(t, runtime.NumCPU(), len(p.Workers()))
destructed := make(chan interface{})
- p.Observe(func(e int, ctx interface{}) {
+ p.Listen(func(e int, ctx interface{}) {
if e == EventWorkerConstruct {
close(destructed)
}