diff options
Diffstat (limited to 'src/client')
| -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() { |