summaryrefslogtreecommitdiffstats
path: root/src/client/common.rs
diff options
context:
space:
mode:
authorLeonard Kugis <leonard@kug.is>2026-10-03 04:44:13 +0200
committerLeonard Kugis <leonard@kug.is>2026-10-03 04:44:13 +0200
commit15e82d6c9def95befad453c0c1de087e1ff821da (patch)
treeb8e8c6bbffbbf464bcc8212bf478b2a470734cca /src/client/common.rs
parent1ce33d3575401ace614d898afece987f0be4b6fc (diff)
downloadaichat-15e82d6c9def95befad453c0c1de087e1ff821da.tar.gz
Fixed subquery tool double addingmain
Diffstat (limited to 'src/client/common.rs')
-rw-r--r--src/client/common.rs3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/client/common.rs b/src/client/common.rs
index ed95291..3fbfd6e 100644
--- a/src/client/common.rs
+++ b/src/client/common.rs
@@ -465,13 +465,14 @@ pub async fn call_chat_completions_streaming(
input: &Input,
client: &dyn Client,
abort_signal: AbortSignal,
+ prefix: Option<String>,
) -> Result<(String, Vec<ToolResult>)> {
let (tx, rx) = unbounded_channel();
let mut handler = SseHandler::new(tx, abort_signal.clone());
let (send_ret, render_ret) = tokio::join!(
client.chat_completions_streaming(input, &mut handler),
- render_stream(rx, client.global_config(), abort_signal.clone()),
+ render_stream(rx, client.global_config(), abort_signal.clone(), prefix),
);
if handler.abort().aborted() {