clone/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-04-24 14:45:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

fmt

Browse Source
This commit is contained in:
Ahmed Ibrahim
2025-08-05 01:29:46 -07:00
parent 635d29d4b7
commit 70c12c19f5
1 changed files with 5 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
codex-rs/core/src/chat_completions.rs
View File

@@ -248,9 +248,7 @@ async fn process_chat_sse<S>(
}],
id: None,
};
let _ = tx_event
.send(Ok(ResponseEvent::OutputItemDone(item)))
.await;
let _ = tx_event.send(Ok(ResponseEvent::OutputItemDone(item))).await;
}
if !reasoning_text.is_empty() {
@@ -262,9 +260,7 @@ async fn process_chat_sse<S>(
}]),
encrypted_content: None,
};
let _ = tx_event
.send(Ok(ResponseEvent::OutputItemDone(item)))
.await;
let _ = tx_event.send(Ok(ResponseEvent::OutputItemDone(item))).await;
}
let _ = tx_event
@@ -374,9 +370,7 @@ async fn process_chat_sse<S>(
}]),
encrypted_content: None,
};
let _ = tx_event
.send(Ok(ResponseEvent::OutputItemDone(item)))
.await;
let _ = tx_event.send(Ok(ResponseEvent::OutputItemDone(item))).await;
}
// Then emit the FunctionCall response item.
@@ -412,9 +406,7 @@ async fn process_chat_sse<S>(
}]),
encrypted_content: None,
};
let _ = tx_event
.send(Ok(ResponseEvent::OutputItemDone(item)))
.await;
let _ = tx_event.send(Ok(ResponseEvent::OutputItemDone(item))).await;
}
}
_ => {}
@@ -645,4 +637,4 @@ impl<S> AggregatedChatStream<S> {
pub(crate) fn streaming_mode(inner: S) -> Self {
Self::new(inner, AggregateMode::Streaming)
}
}
}