Skip to content

Commit 2faa655

Browse files
committed
Remove unused methods/parameters
1 parent ece9af8 commit 2faa655

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

server-common/src/main/java/io/a2a/server/tasks/ResultAggregator.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -106,14 +106,6 @@ public EventKind consumeAll(EventConsumer consumer) throws JSONRPCError {
106106
}
107107

108108
public EventTypeAndInterrupt consumeAndBreakOnInterrupt(EventConsumer consumer, boolean blocking) throws JSONRPCError {
109-
return consumeAndBreakOnInterrupt(consumer, blocking, null, null);
110-
}
111-
112-
public EventTypeAndInterrupt consumeAndBreakOnInterrupt(EventConsumer consumer, boolean blocking, Runnable eventCallback) throws JSONRPCError {
113-
return consumeAndBreakOnInterrupt(consumer, blocking, eventCallback, null);
114-
}
115-
116-
public EventTypeAndInterrupt consumeAndBreakOnInterrupt(EventConsumer consumer, boolean blocking, Runnable eventCallback, CompletableFuture<Void> agentFuture) throws JSONRPCError {
117109
Flow.Publisher<EventQueueItem> allItems = consumer.consumeAll();
118110
AtomicReference<Message> message = new AtomicReference<>();
119111
AtomicBoolean interrupted = new AtomicBoolean(false);

0 commit comments

Comments
 (0)