We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d823afb commit c7d4a02Copy full SHA for c7d4a02
1 file changed
tests/server-common/src/test/java/io/a2a/server/apps/common/AbstractA2AServerTest.java
@@ -1921,7 +1921,11 @@ public void testAuthRequiredWorkflow() throws Exception {
1921
}
1922
};
1923
1924
- Consumer<Throwable> errorHandler = errorRef::set;
+ Consumer<Throwable> errorHandler = error -> {
1925
+ if (!isStreamClosedError(error)) {
1926
+ errorRef.set(error);
1927
+ }
1928
+ };
1929
1930
// Wait for subscription to be established
1931
CountDownLatch subscriptionLatch = new CountDownLatch(1);
0 commit comments