diff --git a/src/providers/compatible.rs b/src/providers/compatible.rs index cca5623..ee1c588 100644 --- a/src/providers/compatible.rs +++ b/src/providers/compatible.rs @@ -277,15 +277,11 @@ fn parse_sse_line(line: &str) -> StreamResult> { /// Convert SSE byte stream to text chunks. async fn sse_bytes_to_chunks( - mut response: reqwest::Response, + response: reqwest::Response, count_tokens: bool, ) -> stream::BoxStream<'static, StreamResult> { - use tokio::io::AsyncBufReadExt; - - let name = "stream".to_string(); - // Create a channel to send chunks - let (mut tx, rx) = tokio::sync::mpsc::channel::>(100); + let (tx, rx) = tokio::sync::mpsc::channel::>(100); tokio::spawn(async move { // Buffer for incomplete lines diff --git a/src/providers/traits.rs b/src/providers/traits.rs index 31f2cf5..f43d099 100644 --- a/src/providers/traits.rs +++ b/src/providers/traits.rs @@ -308,9 +308,9 @@ pub trait Provider: Send + Sync { fn stream_chat_with_history( &self, messages: &[ChatMessage], - model: &str, - temperature: f64, - options: StreamOptions, + _model: &str, + _temperature: f64, + _options: StreamOptions, ) -> stream::BoxStream<'static, StreamResult> { let system = messages .iter()