Fix flaky

minwoox · Oct 14, 2024 · 481ad0c · 481ad0c
1 parent 7acc20e
commit 481ad0c
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/xds/src/test/java/com/linecorp/centraldogma/xds/internal/CdsStreamingTest.java b/xds/src/test/java/com/linecorp/centraldogma/xds/internal/CdsStreamingTest.java
@@ -81,6 +81,11 @@ public void onCompleted() {}
                                                      .setTypeUrl(Resources.V3.CLUSTER_TYPE_URL)
                                                      .build());
         DiscoveryResponse discoveryResponse = queue.take();
+        while (discoveryResponse.getResourcesList().isEmpty()) {
+            // The commited cluster is not yet available. Send ack and receive the next discovery response.
+            sendAck(requestStreamObserver, discoveryResponse);
+            discoveryResponse = queue.take();
+        }
         final String versionInfo1 = discoveryResponse.getVersionInfo();
         assertDiscoveryResponse(versionInfo1, discoveryResponse, fooCluster, queue, "0");
         // Send ack