aboutsummaryrefslogtreecommitdiffstats
path: root/src/cmd/record.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/cmd/record.rs')
-rw-r--r--src/cmd/record.rs16
1 files changed, 10 insertions, 6 deletions
diff --git a/src/cmd/record.rs b/src/cmd/record.rs
index 6a31c5d..6fda88f 100644
--- a/src/cmd/record.rs
+++ b/src/cmd/record.rs
@@ -86,7 +86,7 @@ impl RecordSession {
) -> Self {
let input = crate::async_stdin::Stdin::new();
let process = crate::resize::ResizingProcess::new(
- crate::process::Process::new(cmd, args, input),
+ tokio_pty_process_stream::Process::new(cmd, args, input),
);
Self {
@@ -156,7 +156,9 @@ impl RecordSession {
match component_future::try_ready!(self.process.poll()) {
Some(crate::resize::Event::Process(e)) => {
match e {
- crate::process::Event::CommandStart(..) => {
+ tokio_pty_process_stream::Event::CommandStart {
+ ..
+ } => {
if self.raw_screen.is_none() {
self.raw_screen = Some(
crossterm::RawScreen::into_raw_mode()
@@ -164,13 +166,15 @@ impl RecordSession {
);
}
}
- crate::process::Event::CommandExit(..) => {
+ tokio_pty_process_stream::Event::CommandExit {
+ ..
+ } => {
self.done = true;
}
- crate::process::Event::Output(output) => {
- self.record_bytes(&output);
+ tokio_pty_process_stream::Event::Output { data } => {
+ self.record_bytes(&data);
if let FileState::Open { file } = &mut self.file {
- file.write_frame(&output)?;
+ file.write_frame(&data)?;
}
}
}