diff --git a/pkg/bsync/bsync.go b/pkg/bsync/bsync.go index 5499728..17a4de1 100644 --- a/pkg/bsync/bsync.go +++ b/pkg/bsync/bsync.go @@ -61,7 +61,5 @@ func (w *Worker[T]) Start() { } func (w *Worker[T]) Stop() { - select { - case w.stop <- struct{}{}: - } + w.stop <- struct{}{} } diff --git a/pkg/bsync/bsync_worker_test.go b/pkg/bsync/bsync_worker_test.go index 1d38629..8a1117c 100644 --- a/pkg/bsync/bsync_worker_test.go +++ b/pkg/bsync/bsync_worker_test.go @@ -1,9 +1,10 @@ package bsync_test import ( - "github.com/KyberNetwork/tradinglib/pkg/bsync" "testing" "time" + + "github.com/KyberNetwork/tradinglib/pkg/bsync" ) func TestWorker(t *testing.T) {