Merge remote-tracking branch 'origin/main' into feature/subagent-escalation

# Please enter a commit message to explain why this merge is necessary,
# especially if it merges an updated upstream into a topic branch.
#
# Lines starting with '#' will be ignored, and an empty message aborts
# the commit.

Author: jinnigu

core/src/main/java/com/google/adk/models/Gemini.java

@@ -223,9 +223,24 @@ public Flowable<LlmResponse> generateContent(LlmRequest llmRequest, boolean stre
               effectiveModelName, llmRequest.contents(), config);
 
       return Flowable.defer(
-          () ->
-              processRawResponses(
-                  Flowable.fromFuture(streamFuture).flatMapIterable(iterable -> iterable)));
+              () ->
+                  processRawResponses(
+                      Flowable.fromFuture(streamFuture).flatMapIterable(iterable -> iterable)))
+          .filter(
+              llmResponse ->
+                  llmResponse
+                      .content()
+                      .flatMap(Content::parts)
+                      .map(
+                          parts ->
+                              !parts.isEmpty()
+                                  && parts.stream()
+                                      .anyMatch(
+                                          p ->
+                                              p.functionCall().isPresent()
+                                                  || p.functionResponse().isPresent()
+                                                  || p.text().map(t -> !t.isBlank()).orElse(false)))
+                      .orElse(false));
     } else {
       logger.debug("Sending generateContent request to model {}", effectiveModelName);
       return Flowable.fromFuture(
@@ -253,15 +268,16 @@ static Flowable<LlmResponse> processRawResponses(Flowable<GenerateContentRespons
               Optional<Part> part = GeminiUtil.getPart0FromLlmResponse(currentProcessedLlmResponse);
               String currentTextChunk = part.flatMap(Part::text).orElse("");
 
-              if (!currentTextChunk.isEmpty()) {
+              if (!currentTextChunk.isBlank()) {
                 if (part.get().thought().orElse(false)) {
                   accumulatedThoughtText.append(currentTextChunk);
+                  responsesToEmit.add(
+                      thinkingResponseFromText(currentTextChunk).toBuilder().partial(true).build());
                 } else {
                   accumulatedText.append(currentTextChunk);
+                  responsesToEmit.add(
+                      responseFromText(currentTextChunk).toBuilder().partial(true).build());
                 }
-                LlmResponse partialResponse =
-                    currentProcessedLlmResponse.toBuilder().partial(true).build();
-                responsesToEmit.add(partialResponse);
               } else {
                 if (accumulatedThoughtText.length() > 0
                     && GeminiUtil.shouldEmitAccumulatedText(currentProcessedLlmResponse)) {
@@ -284,22 +300,28 @@ static Flowable<LlmResponse> processRawResponses(Flowable<GenerateContentRespons
         .concatWith(
             Flowable.defer(
                 () -> {
-                  if (accumulatedText.length() > 0 && lastRawResponseHolder[0] != null) {
-                    GenerateContentResponse finalRawResp = lastRawResponseHolder[0];
-                    boolean isStop =
-                        finalRawResp
-                            .candidates()
-                            .flatMap(candidates -> candidates.stream().findFirst())
-                            .flatMap(Candidate::finishReason)
-                            .map(
-                                finishReason -> finishReason.knownEnum() == FinishReason.Known.STOP)
-                            .orElse(false);
-
-                    if (isStop) {
-                      LlmResponse finalAggregatedTextResponse =
-                          responseFromText(accumulatedText.toString());
-                      return Flowable.just(finalAggregatedTextResponse);
+                  GenerateContentResponse finalRawResp = lastRawResponseHolder[0];
+                  if (finalRawResp == null) {
+                    return Flowable.empty();
+                  }
+                  boolean isStop =
+                      finalRawResp
+                          .candidates()
+                          .flatMap(candidates -> candidates.stream().findFirst())
+                          .flatMap(Candidate::finishReason)
+                          .map(finishReason -> finishReason.knownEnum() == FinishReason.Known.STOP)
+                          .orElse(false);
+
+                  if (isStop) {
+                    List<LlmResponse> finalResponses = new ArrayList<>();
+                    if (accumulatedThoughtText.length() > 0) {
+                      finalResponses.add(
+                          thinkingResponseFromText(accumulatedThoughtText.toString()));
+                    }
+                    if (accumulatedText.length() > 0) {
+                      finalResponses.add(responseFromText(accumulatedText.toString()));
                     }
+                    return Flowable.fromIterable(finalResponses);
                   }
                   return Flowable.empty();
                 }));

dev/src/main/java/com/google/adk/web/AgentStaticLoader.java

@@ -37,7 +37,7 @@
  * <p>This class is not a Spring component by itself - instances are created programmatically and
  * then registered as beans via factory methods.
  */
-class AgentStaticLoader implements AgentLoader {
+public class AgentStaticLoader implements AgentLoader {
 
   private final ImmutableMap<String, BaseAgent> agents;
 

pom.xml

@@ -47,7 +47,7 @@
     <otel.version>1.49.0</otel.version>
     <mcp.version>0.14.0</mcp.version>
     <errorprone.version>2.38.0</errorprone.version>
-    <google.genai.version>1.22.0</google.genai.version>
+    <google.genai.version>1.24.0</google.genai.version>
     <protobuf.version>4.32.0</protobuf.version>
     <junit.version>5.11.4</junit.version>
     <mockito.version>5.17.0</mockito.version>
@@ -58,7 +58,7 @@
     <graphviz.version>0.18.1</graphviz.version>
     <ecj.version>3.41.0</ecj.version>
     <maven.version>3.9.0</maven.version>
-    <langchain4j.version>1.4.0</langchain4j.version>
+    <langchain4j.version>1.8.0</langchain4j.version>
     <slf4j.version>2.0.17</slf4j.version>
     <truth.version>1.4.4</truth.version>
     <jspecify.version>1.0.0</jspecify.version>