aboutsummaryrefslogtreecommitdiffstats
path: root/examples/tokio.rs
diff options
context:
space:
mode:
authorJesse Luehrs <doy@tozt.net>2021-03-03 01:26:18 -0500
committerJesse Luehrs <doy@tozt.net>2021-03-03 01:26:18 -0500
commitc78084caca2563c52e563901a94e4d094e88cd1c (patch)
tree7a7e5ebb51857005307be5d7069fe6bb9421064c /examples/tokio.rs
parentf7531c298e90252507c6224b78219a560c8a629f (diff)
downloadpty-process-c78084caca2563c52e563901a94e4d094e88cd1c.tar.gz
pty-process-c78084caca2563c52e563901a94e4d094e88cd1c.zip
refactor examples
Diffstat (limited to 'examples/tokio.rs')
-rw-r--r--examples/tokio.rs34
1 files changed, 2 insertions, 32 deletions
diff --git a/examples/tokio.rs b/examples/tokio.rs
index 42cd643..2441c61 100644
--- a/examples/tokio.rs
+++ b/examples/tokio.rs
@@ -1,43 +1,13 @@
use pty_process::Command as _;
-use std::os::unix::io::AsRawFd as _;
use std::os::unix::process::ExitStatusExt as _;
use tokio::io::{AsyncReadExt as _, AsyncWriteExt as _};
-struct RawGuard {
- termios: nix::sys::termios::Termios,
-}
-
-impl RawGuard {
- fn new() -> Self {
- let stdin = std::io::stdin().as_raw_fd();
- let termios = nix::sys::termios::tcgetattr(stdin).unwrap();
- let mut termios_raw = termios.clone();
- nix::sys::termios::cfmakeraw(&mut termios_raw);
- nix::sys::termios::tcsetattr(
- stdin,
- nix::sys::termios::SetArg::TCSANOW,
- &termios_raw,
- )
- .unwrap();
- Self { termios }
- }
-}
-
-impl Drop for RawGuard {
- fn drop(&mut self) {
- let stdin = std::io::stdin().as_raw_fd();
- let _ = nix::sys::termios::tcsetattr(
- stdin,
- nix::sys::termios::SetArg::TCSANOW,
- &self.termios,
- );
- }
-}
+mod raw_guard;
async fn run(
child: &mut pty_process::tokio::Child,
) -> std::result::Result<(), Box<dyn std::error::Error>> {
- let _raw = RawGuard::new();
+ let _raw = raw_guard::RawGuard::new();
let mut in_buf = [0_u8; 4096];
let mut out_buf = [0_u8; 4096];