diff --git a/fxgcppubsub/reactor/ack/reactor_test.go b/fxgcppubsub/reactor/ack/reactor_test.go index abc6424..ff506d8 100644 --- 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) })