Skip to content

Commit 0217cfd

Browse files
Update tests/server-common/src/test/java/org/a2aproject/sdk/server/apps/common/AbstractA2AServerTest.java
Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>
1 parent ea61e0f commit 0217cfd

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

‎tests/server-common/src/test/java/org/a2aproject/sdk/server/apps/common/AbstractA2AServerTest.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -806,8 +806,8 @@ public void testSubscribeExistingTaskSuccess() throws Exception {
806806

807807
// Wait for EventConsumer polling loop to start (transport-level subscription
808808
// does not guarantee the consumer is ready to receive events)
809-
assertTrue(waitForChildQueueCountToBe(MINIMAL_TASK.id(), childCountBefore + 1, 15000),
810-
"subscribeToTask child queue should be created");
809+
assertTrue(awaitChildQueueCountStable(MINIMAL_TASK.id(), childCountBefore + 1, 15000),
810+
"subscribeToTask child queue should be created and stable");
811811

812812
// Enqueue events on the server
813813
List<Event> events = List.of(

0 commit comments

Comments
 (0)