Cleanup

Author: kabir

core/src/main/java/io/a2a/server/events/EventQueue.java

@@ -123,7 +123,7 @@ public void enqueueEvent(Event event) {
 
         @Override
         public void awaitQueuePollerStart() throws InterruptedException {
-            log.debug("Waiting for queue poller to start om {}", this);
+            log.debug("Waiting for queue poller to start on {}", this);
             pollingStartedLatch.await(10, TimeUnit.SECONDS);
             log.debug("Queue poller started on {}", this);
         }

quarkus-sdk/src/test/java/io/a2a/server/apps/quarkus/A2AServerResourceTest.java

@@ -878,25 +878,4 @@ private CompletableFuture<HttpResponse<Stream<String>>> initialiseStreamingReque
     private static class BreakException extends RuntimeException {
 
     }
-
-    public static void main(String[] args) {
-        List<String> l = List.of("A", "B", "C", "D", "E");
-
-        System.out.println("== For loop");
-        for (String s : l) {
-            System.out.println(s);
-            if (s.equals("C")) {
-                break;
-            }
-        }
-
-        System.out.println("== ForEach");
-        Stream<String> str = l.stream();
-        str.forEach(s -> {
-            System.out.println(s);
-            if (s.equals("C")) {
-                throw new RuntimeException();
-            }
-        });
-    }
 }