Merge pull request #1094 from dennysfredericci/bugfix/duplicated-messages-in-memory-for-anthropic-models

geoand · web-flow · commit 3deb3c5c031c · 2024-11-22T08:36:42.000+02:00
Remove duplicate invocation from handleMessageStop.
diff --git a/model-providers/anthropic/deployment/src/test/java/io/quarkiverse/langchain4j/anthropic/deployment/AnthropicStreamingChatLanguageModelSmokeTest.java b/model-providers/anthropic/deployment/src/test/java/io/quarkiverse/langchain4j/anthropic/deployment/AnthropicStreamingChatLanguageModelSmokeTest.java
@@ -182,6 +182,7 @@ void streaming() {
 
                 event: message_stop
                 data: {"type":"message_stop"           }
+
                 """;
 
         wireMockServer.stubFor(
diff --git a/model-providers/anthropic/runtime/src/main/java/io/quarkiverse/langchain4j/anthropic/QuarkusAnthropicClient.java b/model-providers/anthropic/runtime/src/main/java/io/quarkiverse/langchain4j/anthropic/QuarkusAnthropicClient.java
@@ -230,7 +230,6 @@ public void onFailure(Throwable failure) {
 
         @Override
         public void onCompletion() {
-            handleMessageStop();
         }
 
         @Override

Original file line number	Diff line number	Diff line change
`@@ -230,7 +230,6 @@ public void onFailure(Throwable failure) {`
`230`	`230`
`231`	`231`	`@Override`
`232`	`232`	`public void onCompletion() {`
`233`		`- handleMessageStop();`
`234`	`233`	`}`
`235`	`234`
`236`	`235`	`@Override`