adding time to test
@@ -713,7 +713,7 @@ public class DrainTests {
assertTrue(handler.getExceptionCount() == 0);
CompletableFuture<Boolean> tracker = subCon.drain(Duration.ofSeconds(2));
- assertFalse(tracker.get(3, TimeUnit.SECONDS));
+ assertFalse(tracker.get(5, TimeUnit.SECONDS));
assertFalse(((NatsConnection) subCon).isDrained());
assertTrue(handler.getExceptionCount() == 0); // Don't throw during drain from reader
assertTrue(Connection.Status.CLOSED == subCon.getStatus());
