aboutsummaryrefslogtreecommitdiffstats
path: root/examples/smol.rs
diff options
context:
space:
mode:
Diffstat (limited to 'examples/smol.rs')
-rw-r--r--examples/smol.rs84
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!()
-}