chore: add consumer base fetch err unit test

Trendyol · Dec 16, 2023 · 6be80c7 · 6be80c7
1 parent 56d3376
commit 6be80c7
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/consumer_base_test.go b/consumer_base_test.go
@@ -5,6 +5,7 @@ import (
 	"errors"
 	"sync"
 	"testing"
+	"time"
 
 	"github.com/google/go-cmp/cmp"
 
@@ -26,6 +27,9 @@ func Test_base_startConsume(t *testing.T) {
 
 		// When
 		go b.startConsume()
+
+		// Ensure some time passes
+		time.Sleep(3 * time.Second)
 		b.quit <- struct{}{}
 
 		// Then