Skip to content

Commit 31cc6b2

Browse files
Update server-common/src/main/java/io/a2a/server/requesthandlers/DefaultRequestHandler.java
Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>
1 parent 8dd100d commit 31cc6b2

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

server-common/src/main/java/io/a2a/server/requesthandlers/DefaultRequestHandler.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -269,10 +269,7 @@ public EventKind onMessageSend(MessageSendParams params, ServerCallContext conte
269269
EventQueue queue = queueManager.createOrTap(taskId);
270270
ResultAggregator resultAggregator = new ResultAggregator(mss.taskManager, null, executor);
271271

272-
boolean blocking = false; // Default to non-blocking behavior
273-
if (params.configuration() != null && Boolean.TRUE.equals(params.configuration().blocking())) {
274-
blocking = true;
275-
}
272+
boolean blocking = params.configuration() != null && Boolean.TRUE.equals(params.configuration().blocking());
276273

277274
boolean interruptedOrNonBlocking = false;
278275

0 commit comments

Comments
 (0)