From 5d4f5345b13171a47f022d34d39609c2f4329069 Mon Sep 17 00:00:00 2001 From: hannahrogers-google <52459909+hannahrogers-google@users.noreply.github.com> Date: Fri, 4 Sep 2020 08:01:43 -0400 Subject: [PATCH] fix: make subscriberIT test less flaky (#340) * fix: make subscriberIt less flaky --- samples/snippets/src/test/java/pubsub/SubscriberIT.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/samples/snippets/src/test/java/pubsub/SubscriberIT.java b/samples/snippets/src/test/java/pubsub/SubscriberIT.java index be9e4e3d2..f69acd8cb 100644 --- a/samples/snippets/src/test/java/pubsub/SubscriberIT.java +++ b/samples/snippets/src/test/java/pubsub/SubscriberIT.java @@ -165,19 +165,19 @@ public void testSubscriber() throws Exception { assertThat(bout.toString()).contains("Data: Hello " + i); } - publishSomeMessages(10); + publishSomeMessages(3); bout.reset(); // Test subscribe synchronously. SubscribeSyncExample.subscribeSyncExample(projectId, subscriptionId, 10); - for (int i = 0; i < 10; i++) { + for (int i = 0; i < 3; i++) { assertThat(bout.toString()).contains("Hello " + i); } - publishSomeMessages(10); + publishSomeMessages(3); bout.reset(); // Test subscribe synchronously with lease management. SubscribeSyncWithLeaseExample.subscribeSyncWithLeaseExample(projectId, subscriptionId, 10); - for (int i = 0; i < 10; i++) { + for (int i = 0; i < 3; i++) { assertThat(bout.toString()).contains("Hello " + i); } }