Skip to content

Commit fd0cdb7

Browse files
authored
fix: fix TCK failure (#153)
# Description Thank you for opening a Pull Request! Before submitting your PR, there are a few things you can do to make sure it goes smoothly: - [x] Follow the [`CONTRIBUTING` Guide](../CONTRIBUTING.md). - [x] Make your Pull Request title in the <https://www.conventionalcommits.org/> specification. - Important Prefixes for [release-please](https://github.com/googleapis/release-please): - `fix:` which represents bug fixes, and correlates to a [SemVer](https://semver.org/) patch. - `feat:` represents a new feature, and correlates to a SemVer minor. - `feat!:`, or `fix!:`, `refactor!:`, etc., which represent a breaking change (indicated by the `!`) and will result in a SemVer major. - [x] Ensure the tests pass - [x] Appropriate READMEs were updated (if necessary) Fixes #<issue_number_goes_here> 🦕
1 parent d8fa0e6 commit fd0cdb7

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,8 +162,9 @@ public EventKind onMessageSend(MessageSendParams params) throws JSONRPCError {
162162
ResultAggregator.EventTypeAndInterrupt etai = null;
163163
try {
164164
EventConsumer consumer = new EventConsumer(queue);
165-
etai = resultAggregator.consumeAndBreakOnInterrupt(consumer);
166165
producerRunnable.addDoneCallback(consumer.createAgentRunnableDoneCallback());
166+
etai = resultAggregator.consumeAndBreakOnInterrupt(consumer);
167+
167168
if (etai == null) {
168169
log.debug("No result, throwing InternalError");
169170
throw new InternalError("No result");

0 commit comments

Comments
 (0)