Use async at places, use &self instead of self: &Self (#3594)

1 files changed, 4 insertions, 3 deletions

diff --git a/cli/ops/process.rs b/cli/ops/process.rs
index 92474cc4f..80ce4b1ac 100644
--- a/cli/ops/process.rs
+++ b/cli/ops/process.rs
@@ -220,7 +220,8 @@ fn op_run_status(
     state: state.clone(),
   };
 
-  let future = future.and_then(move |run_status| {
+  let future = async move {
+    let run_status = future.await?;
     let code = run_status.code();
 
     #[cfg(unix)]
@@ -233,12 +234,12 @@ fn op_run_status(
       .expect("Should have either an exit code or a signal.");
     let got_signal = signal.is_some();
 
-    futures::future::ok(json!({
+    Ok(json!({
        "gotSignal": got_signal,
        "exitCode": code.unwrap_or(-1),
        "exitSignal": signal.unwrap_or(-1),
     }))
-  });
+  };
 
   let pool = futures::executor::ThreadPool::new().unwrap();
   let handle = pool.spawn_with_handle(future).unwrap();