Added throttling limitation

Signed-off-by: vhnes <ext-vladyslav.hnes@here.com>
heremaps · May 14, 2024 · 6a0cfb2 · 6a0cfb2
1 parent 4f96dad
commit 6a0cfb2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/xyz-hub-test/src/test/java/com/here/xyz/hub/rest/ClientThrottlingIT.java b/xyz-hub-test/src/test/java/com/here/xyz/hub/rest/ClientThrottlingIT.java
@@ -39,7 +39,7 @@ public void testClientThrottling() {
         AtomicInteger tooManyRequestsCount = new AtomicInteger(0);
         ExecutorService executorService = newFixedThreadPool(20);
 
-        CompletableFuture<?>[] futures = IntStream.range(0, 15)
+        CompletableFuture<?>[] futures = IntStream.range(0, 10)
                 .mapToObj(i -> CompletableFuture.runAsync(() ->
                         {
                             try {
@@ -59,7 +59,7 @@ public void testClientThrottling() {
 
         CompletableFuture.allOf(futures).join();
         assertEquals(7, successfulCount.get());
-        assertEquals(8, tooManyRequestsCount.get());
+        assertEquals(3, tooManyRequestsCount.get());
     }
 
     private HttpResponse<String> getIterateSpace(String spaceId, AuthProfile profile) throws IOException, InterruptedException {