fix(fxgcppubsub): Fixed nack reactor

ankorstore · Jul 10, 2024 · 858f4dc · 858f4dc
1 parent d58771f
commit 858f4dc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/fxgcppubsub/reactor/ack/reactor_test.go b/fxgcppubsub/reactor/ack/reactor_test.go
@@ -62,7 +62,7 @@ func TestAckReactor(t *testing.T) {
 			assert.NoError(t, rErr)
 		}()
 
-		data, err := waiter.WaitMaxDuration(context.Background(), 1*time.Millisecond)
+		data, err := waiter.WaitMaxDuration(context.Background(), 5*time.Millisecond)
 		assert.NoError(t, err)
 		assert.Equal(t, []string{"test-id"}, data)
 	})
@@ -83,7 +83,7 @@ func TestAckReactor(t *testing.T) {
 			assert.NoError(t, rErr)
 		}()
 
-		data, err := waiter.WaitMaxDuration(context.Background(), 1*time.Millisecond)
+		data, err := waiter.WaitMaxDuration(context.Background(), 5*time.Millisecond)
 		assert.NoError(t, err)
 		assert.Equal(t, []string{"test-id"}, data)
 	})