Replace Thread.sleep with Awaitility for more robust synchronization

Co-authored-by: brendandburns <[email protected]>

Author: Copilot

spring/src/test/java/io/kubernetes/client/spring/extended/controller/KubernetesInformerCreatorTest.java

@@ -19,6 +19,7 @@
 import static com.github.tomakehurst.wiremock.client.WireMock.urlPathEqualTo;
 import static com.github.tomakehurst.wiremock.core.WireMockConfiguration.options;
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
 
 import com.github.tomakehurst.wiremock.core.Admin;
 import com.github.tomakehurst.wiremock.extension.Parameters;
@@ -38,6 +39,7 @@
 import io.kubernetes.client.openapi.models.V1PodList;
 import io.kubernetes.client.util.ClientBuilder;
 import io.kubernetes.client.util.generic.GenericKubernetesApi;
+import java.time.Duration;
 import java.util.Collections;
 import java.util.concurrent.Semaphore;
 import org.junit.jupiter.api.Test;
@@ -167,21 +169,27 @@ void informerInjection() throws InterruptedException {
     getCount.acquire(2);
     watchCount.acquire(2);
 
-    // Add a small delay to ensure WireMock has finished recording the requests
-    Thread.sleep(100);
-
-    apiServer.verify(
-        1,
-        getRequestedFor(urlPathEqualTo("/api/v1/pods")).withQueryParam("watch", equalTo("false")));
-    apiServer.verify(
-        getRequestedFor(urlPathEqualTo("/api/v1/pods")).withQueryParam("watch", equalTo("true")));
-    apiServer.verify(
-        1,
-        getRequestedFor(urlPathEqualTo("/api/v1/namespaces/default/configmaps"))
-            .withQueryParam("watch", equalTo("false")));
-    apiServer.verify(
-        getRequestedFor(urlPathEqualTo("/api/v1/namespaces/default/configmaps"))
-            .withQueryParam("watch", equalTo("true")));
+    // Use Awaitility to poll until WireMock has recorded the requests
+    await()
+        .atMost(Duration.ofSeconds(5))
+        .pollInterval(Duration.ofMillis(50))
+        .untilAsserted(
+            () -> {
+              apiServer.verify(
+                  1,
+                  getRequestedFor(urlPathEqualTo("/api/v1/pods"))
+                      .withQueryParam("watch", equalTo("false")));
+              apiServer.verify(
+                  getRequestedFor(urlPathEqualTo("/api/v1/pods"))
+                      .withQueryParam("watch", equalTo("true")));
+              apiServer.verify(
+                  1,
+                  getRequestedFor(urlPathEqualTo("/api/v1/namespaces/default/configmaps"))
+                      .withQueryParam("watch", equalTo("false")));
+              apiServer.verify(
+                  getRequestedFor(urlPathEqualTo("/api/v1/namespaces/default/configmaps"))
+                      .withQueryParam("watch", equalTo("true")));
+            });
 
     assertThat(new Lister<>(podInformer.getIndexer()).list()).hasSize(1);
     assertThat(new Lister<>(configMapInformer.getIndexer()).list()).hasSize(1);