diff --git a/src/main/java/io/github/ollama4j/models/chat/OllamaChatStreamObserver.java b/src/main/java/io/github/ollama4j/models/chat/OllamaChatStreamObserver.java index 9f1bf7f..bfa2b7c 100644 --- a/src/main/java/io/github/ollama4j/models/chat/OllamaChatStreamObserver.java +++ b/src/main/java/io/github/ollama4j/models/chat/OllamaChatStreamObserver.java @@ -11,8 +11,6 @@ public class OllamaChatStreamObserver { private List responseParts = new ArrayList<>(); - private String message = ""; - public OllamaChatStreamObserver(OllamaStreamHandler streamHandler) { this.streamHandler = streamHandler; } @@ -23,8 +21,7 @@ public class OllamaChatStreamObserver { } protected void handleCurrentResponsePart(OllamaChatResponseModel currentResponsePart) { - message = message + currentResponsePart.getMessage().getContent(); - streamHandler.accept(message); + streamHandler.accept(currentResponsePart.getMessage().getContent()); }