Simplify testWatch

docker · Dec 17, 2021 · 94321b2 · 94321b2
1 parent 1dd4d4f
commit 94321b2
Showing 1 changed file with 4 additions and 11 deletions.
diff --git a/testutils/utils.go b/testutils/utils.go
@@ -160,19 +160,12 @@ func testWatch(t *testing.T, kv store.Store) {
 
 	// Update loop
 	go func() {
-		timeout := time.After(1 * time.Second)
-		tick := time.Tick(250 * time.Millisecond)
-		for {
-			select {
-			case <-timeout:
-				return
-			case <-tick:
-				err := kv.Put(key, newValue, nil)
-				if assert.NoError(t, err) {
-					continue
-				}
+		for i := 0; i < 4; i++ {
+			err := kv.Put(key, newValue, nil)
+			if !assert.NoError(t, err) {
 				return
 			}
+			time.Sleep(50 * time.Microsecond)
 		}
 	}()