diff options
Diffstat (limited to 'examples/smol.rs')
-rw-r--r-- | examples/smol.rs | 84 |
1 files changed, 0 insertions, 84 deletions
diff --git a/examples/smol.rs b/examples/smol.rs deleted file mode 100644 index 651ff10..0000000 --- a/examples/smol.rs +++ /dev/null @@ -1,84 +0,0 @@ -mod raw_guard; - -#[cfg(feature = "async")] -mod main { - use smol::io::{AsyncReadExt as _, AsyncWriteExt as _}; - - pub async fn run( - child: &async_process::Child, - pty: &pty_process::Pty, - ) -> std::result::Result<(), Box<dyn std::error::Error>> { - let _raw = super::raw_guard::RawGuard::new(); - - let mut input_pty = pty; - let mut output_pty = pty; - let ex = smol::Executor::new(); - - let input = ex.spawn(async { - let mut buf = [0_u8; 4096]; - let mut stdin = smol::Unblock::new(std::io::stdin()); - loop { - match stdin.read(&mut buf).await { - Ok(bytes) => { - input_pty.write_all(&buf[..bytes]).await.unwrap(); - } - Err(e) => { - eprintln!("stdin read failed: {:?}", e); - break; - } - } - } - }); - let output = ex.spawn(async { - let mut buf = [0_u8; 4096]; - let mut stdout = smol::Unblock::new(std::io::stdout()); - loop { - match output_pty.read(&mut buf).await { - Ok(bytes) => { - stdout.write_all(&buf[..bytes]).await.unwrap(); - stdout.flush().await.unwrap(); - } - Err(e) => { - eprintln!("pty read failed: {:?}", e); - break; - } - } - } - }); - - let wait = async { - child.status_no_drop().await.unwrap(); - }; - - ex.run(smol::future::or(smol::future::or(input, output), wait)) - .await; - - Ok(()) - } -} - -#[cfg(feature = "async")] -fn main() { - use std::os::unix::process::ExitStatusExt as _; - - let status = smol::block_on(async { - let pty = pty_process::Pty::new().unwrap(); - pty.resize(pty_process::Size::new(24, 80)).unwrap(); - let mut child = pty_process::Command::new("tac") - // .args(&["500"]) - .spawn(&pty) - .unwrap(); - main::run(&child, &pty).await.unwrap(); - child.status().await.unwrap() - }); - std::process::exit( - status - .code() - .unwrap_or_else(|| status.signal().unwrap_or(0) + 128), - ); -} - -#[cfg(not(feature = "async"))] -fn main() { - unimplemented!() -} |