We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
call_mcp_message
1 parent 8519509 commit 0b00e34Copy full SHA for 0b00e34
src/services/ws/stable/llm.rs
@@ -208,7 +208,13 @@ pub async fn chat(
208
log::info!("tool {} call message: {}", &function.function.name, message);
209
if !message.is_empty() {
210
let (tts_resp_tx, tts_resp_rx) = tokio::sync::mpsc::unbounded_channel();
211
- drop(tts_resp_tx);
+
212
+ tts_tx
213
+ .send((message.to_string(), tts_resp_tx))
214
+ .await
215
+ .map_err(|e| {
216
+ anyhow::anyhow!("error sending tts request for llm chunk: {e}")
217
+ })?;
218
219
chunks_tx.send((message, tts_resp_rx)).map_err(|e| {
220
anyhow::anyhow!(
0 commit comments