diff options
| author | Leonard Kugis <leonard@kug.is> | 2026-10-03 04:44:13 +0200 |
|---|---|---|
| committer | Leonard Kugis <leonard@kug.is> | 2026-10-03 04:44:13 +0200 |
| commit | 15e82d6c9def95befad453c0c1de087e1ff821da (patch) | |
| tree | b8e8c6bbffbbf464bcc8212bf478b2a470734cca /src/client/common.rs | |
| parent | 1ce33d3575401ace614d898afece987f0be4b6fc (diff) | |
| download | aichat-15e82d6c9def95befad453c0c1de087e1ff821da.tar.gz | |
Fixed subquery tool double addingmain
Diffstat (limited to 'src/client/common.rs')
| -rw-r--r-- | src/client/common.rs | 3 |
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() { |
