summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rwxr-xr-xsync_worker_test.go1
1 files changed, 1 insertions, 0 deletions
diff --git a/sync_worker_test.go b/sync_worker_test.go
index 890a2365..c4febbb4 100755
--- a/sync_worker_test.go
+++ b/sync_worker_test.go
@@ -166,6 +166,7 @@ func Test_Broken(t *testing.T) {
w.AddListener(func(event interface{}) {
assert.Contains(t, string(event.(WorkerEvent).Payload.([]byte)), "undefined_function()")
wg.Done()
+ return
})
syncWorker, err := NewSyncWorker(w)