diff options
| author | sigoden <sigoden@gmail.com> | 2023-03-08 16:06:24 +0800 |
|---|---|---|
| committer | sigoden <sigoden@gmail.com> | 2023-03-08 16:06:24 +0800 |
| commit | 2a7a6f5f27ae6343c1aa235563cbddb6cb40f557 (patch) | |
| tree | 1ab01b81d26a5c2a820063e0700ae69781d15440 /src/render/mod.rs | |
| parent | 4e729db237dbfb93d32bfa43b60a09be07d49630 (diff) | |
| download | aichat-2a7a6f5f27ae6343c1aa235563cbddb6cb40f557.tar.gz | |
chore: no longer ignore any error
Diffstat (limited to 'src/render/mod.rs')
| -rw-r--r-- | src/render/mod.rs | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/render/mod.rs b/src/render/mod.rs index efbcdd7..b06ab31 100644 --- a/src/render/mod.rs +++ b/src/render/mod.rs @@ -7,6 +7,7 @@ pub use self::markdown::MarkdownRender; use self::repl::repl_render_stream; use crate::client::ChatGptClient; +use crate::print_now; use crate::repl::{ReplyStreamHandler, SharedAbortSignal}; use anyhow::Result; use crossbeam::channel::unbounded; @@ -26,11 +27,15 @@ pub fn render_stream( let (tx, rx) = unbounded(); let abort_clone = abort.clone(); spawn(move || { - let _ = if repl { + let err = if repl { repl_render_stream(rx, abort) } else { cmd_render_stream(rx, abort) }; + if let Err(err) = err { + let err = format!("{err:?}"); + print_now!("{}\n\n", err.trim()); + } drop(wg); }); ReplyStreamHandler::new(Some(tx), abort_clone) |
