1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
mod cmd;
mod markdown;
mod repl;
use self::cmd::cmd_render_stream;
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;
use crossbeam::sync::WaitGroup;
use std::thread::spawn;
pub fn render_stream(
input: &str,
client: &ChatGptClient,
highlight: bool,
repl: bool,
abort: SharedAbortSignal,
wg: WaitGroup,
) -> Result<String> {
let mut stream_handler = if highlight {
let (tx, rx) = unbounded();
let abort_clone = abort.clone();
spawn(move || {
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), repl, abort_clone)
} else {
drop(wg);
ReplyStreamHandler::new(None, repl, abort)
};
client.send_message_streaming(input, &mut stream_handler)?;
let buffer = stream_handler.get_buffer();
Ok(buffer.to_string())
}
|
