Make test less time-dependent

acogoluegnes · acogoluegnes · commit f358de3226ff · 2021-12-16T09:48:17.000+01:00
diff --git a/src/test/java/com/rabbitmq/stream/impl/StreamProducerTest.java b/src/test/java/com/rabbitmq/stream/impl/StreamProducerTest.java
@@ -377,8 +377,8 @@ void producerShouldBeClosedWhenStreamIsDeleted(int subEntrySize, TestInfo info)
 
     environment.deleteStream(s);
 
-    waitAtMost(10, () -> !producer.isOpen());
-    assertThat(errorCodes).isNotEmpty().contains(lastExpectedErrorCode);
+    waitAtMost(() -> !producer.isOpen());
+    waitAtMost(() -> errorCodes.contains(lastExpectedErrorCode));
   }
 
   @ParameterizedTest

Original file line number	Diff line number	Diff line change
`@@ -377,8 +377,8 @@ void producerShouldBeClosedWhenStreamIsDeleted(int subEntrySize, TestInfo info)`
`377`	`377`
`378`	`378`	`environment.deleteStream(s);`
`379`	`379`
`380`		`- waitAtMost(10, () -> !producer.isOpen());`
`381`		`- assertThat(errorCodes).isNotEmpty().contains(lastExpectedErrorCode);`
	`380`	`+ waitAtMost(() -> !producer.isOpen());`
	`381`	`+ waitAtMost(() -> errorCodes.contains(lastExpectedErrorCode));`
`382`	`382`	`}`
`383`	`383`
`384`	`384`	`@ParameterizedTest`