fix: fix retryAssert (#996)

apache · Mar 22, 2023 · 6c3ee77 · 6c3ee77
1 parent 04ad521
commit 6c3ee77
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pulsar/helper_for_test.go b/pulsar/helper_for_test.go
@@ -177,9 +177,14 @@ func retryAssert(t assert.TestingT, times int, milliseconds int, update func(),
 	for i := 0; i < times; i++ {
 		time.Sleep(time.Duration(milliseconds) * time.Millisecond)
 		update()
-		if assert(nil) {
+		if assert(fakeAssertT{}) {
 			break
 		}
 	}
 	assert(t)
 }
+
+type fakeAssertT struct{}
+
+func (fa fakeAssertT) Errorf(format string, args ...interface{}) {
+}