diff options
| author | Valery Piashchynski <[email protected]> | 2020-12-17 10:19:01 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2020-12-17 10:19:01 +0300 |
| commit | acb53196f8ff4518c515225b39c6fb2bac64faae (patch) | |
| tree | 3c016e03132a38ec3dd3fce737120a0fdc9642c9 /pkg/pool/static_pool_test.go | |
| parent | 8422e300f64f20d86ffccf773d41109285bbc12d (diff) | |
Update events handler, add mutex to push
Diffstat (limited to 'pkg/pool/static_pool_test.go')
| -rwxr-xr-x | pkg/pool/static_pool_test.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/pkg/pool/static_pool_test.go b/pkg/pool/static_pool_test.go index 0794b8e6..dd33a1a6 100755 --- a/pkg/pool/static_pool_test.go +++ b/pkg/pool/static_pool_test.go @@ -175,7 +175,7 @@ func Test_StaticPool_Broken_Replace(t *testing.T) { assert.NoError(t, err) assert.NotNil(t, p) - block := make(chan struct{}) + block := make(chan struct{}, 1) p.AddListener(func(event interface{}) { if wev, ok := event.(events.WorkerEvent); ok { |