aboutsummaryrefslogtreecommitdiffstats
path: root/examples/tokio.rs
diff options
context:
space:
mode:
Diffstat (limited to 'examples/tokio.rs')
-rw-r--r--examples/tokio.rs9
1 files changed, 5 insertions, 4 deletions
diff --git a/examples/tokio.rs b/examples/tokio.rs
index 16083c7..55436c2 100644
--- a/examples/tokio.rs
+++ b/examples/tokio.rs
@@ -6,7 +6,8 @@ mod main {
use tokio_util::compat::FuturesAsyncReadCompatExt as _;
pub async fn run(
- child: &pty_process::Child,
+ child: &async_process::Child,
+ pty: &pty_process::Pty,
) -> std::result::Result<(), Box<dyn std::error::Error>> {
let _raw = super::raw_guard::RawGuard::new();
@@ -15,9 +16,9 @@ mod main {
let mut stdin = tokio::io::stdin();
let mut stdout = tokio::io::stdout();
+ let mut pty = pty.compat();
loop {
- let mut pty = child.pty().compat();
tokio::select! {
bytes = stdin.read(&mut in_buf) => match bytes {
Ok(bytes) => {
@@ -55,9 +56,9 @@ async fn main() {
pty.resize(pty_process::Size::new(24, 80)).unwrap();
let mut child = pty_process::Command::new("tac")
// .args(&["500"])
- .spawn(pty)
+ .spawn(&pty)
.unwrap();
- main::run(&child).await.unwrap();
+ main::run(&child, &pty).await.unwrap();
let status = child.status().await.unwrap();
std::process::exit(
status