harald/zeroclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 3

fix(clippy): satisfy strict delta lints in SSE streaming path

Browse source
This commit is contained in:
Will Sarg 2026-02-17 09:26:21 -05:00
parent 98d06cba6b
commit a62c7a5893
1 changed files with 5 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

19
src/providers/compatible.rs
View file

@ -281,7 +281,7 @@ fn parse_sse_line(line: &str) -> StreamResult<Option<String>> {
} }
/// Convert SSE byte stream to text chunks. /// Convert SSE byte stream to text chunks.
async fn sse_bytes_to_chunks( fn sse_bytes_to_chunks(
response: reqwest::Response, response: reqwest::Response,
count_tokens: bool, count_tokens: bool,
) -> stream::BoxStream<'static, StreamResult<StreamChunk>> { ) -> stream::BoxStream<'static, StreamResult<StreamChunk>> {
@ -337,10 +337,7 @@ async fn sse_bytes_to_chunks(
return; // Receiver dropped return; // Receiver dropped
} }
} }
Ok(None) => { Ok(None) => {}
// Empty line or [DONE] sentinel - continue
continue;
}
Err(e) => { Err(e) => {
let _ = tx.send(Err(e)).await; let _ = tx.send(Err(e)).await;
return; return;
@ -361,10 +358,7 @@ async fn sse_bytes_to_chunks(
// Convert channel receiver to stream // Convert channel receiver to stream
stream::unfold(rx, |mut rx| async { stream::unfold(rx, |mut rx| async {
match rx.recv().await { rx.recv().await.map(|chunk| (chunk, rx))
Some(chunk) => Some((chunk, rx)),
None => None,
}
}) })
.boxed() .boxed()
} }
@ -767,7 +761,7 @@ impl Provider for OpenAiCompatibleProvider {
} }
// Convert to chunk stream and forward to channel // Convert to chunk stream and forward to channel
let mut chunk_stream = sse_bytes_to_chunks(response, options.count_tokens).await; let mut chunk_stream = sse_bytes_to_chunks(response, options.count_tokens);
while let Some(chunk) = chunk_stream.next().await { while let Some(chunk) = chunk_stream.next().await {
if tx.send(chunk).await.is_err() { if tx.send(chunk).await.is_err() {
break; // Receiver dropped break; // Receiver dropped
@ -777,10 +771,7 @@ impl Provider for OpenAiCompatibleProvider {
// Convert channel receiver to stream // Convert channel receiver to stream
stream::unfold(rx, |mut rx| async move { stream::unfold(rx, |mut rx| async move {
match rx.recv().await { rx.recv().await.map(|chunk| (chunk, rx))
Some(chunk) => Some((chunk, rx)),
None => None,
}
}) })
.boxed() .boxed()
} }