Align Prose Test with Spec

Author: nhachicha

driver-sync/src/test/functional/com/mongodb/client/ServerDiscoveryAndMonitoringProseTests.java

@@ -322,16 +322,12 @@ public void testConnectionPoolBackpressure() throws InterruptedException {
                     }
                 }
 
-                long connectionErrorCount = connectionPoolListener.getEvents().stream()
-                        .filter(e -> e instanceof ConnectionCheckOutFailedEvent)
-                        .map(e -> ((ConnectionCheckOutFailedEvent) e).getReason())
-                        .filter(r -> r == ConnectionCheckOutFailedEvent.Reason.CONNECTION_ERROR)
-                        .count();
-                assertTrue("Expected at least 10 ConnectionCheckOutFailedEvents with CONNECTION_ERROR, but got "
-                                + connectionErrorCount,
-                        connectionErrorCount >= 10);
+                int failedCheckOutCount = connectionPoolListener.countEvents(ConnectionCheckOutFailedEvent.class);
+                assertTrue("Expected at least 10 ConnectionCheckOutFailedEvents, but got " + failedCheckOutCount,
+                        failedCheckOutCount >= 10);
                 assertEquals(0, connectionPoolListener.countEvents(ConnectionPoolClearedEvent.class));
             } finally {
+                Thread.sleep(1000);
                 adminDatabase.runCommand(new Document("setParameter", 1)
                         .append("ingressConnectionEstablishmentRateLimiterEnabled", false));
             }