process: Track tokio-core master

This commit is contained in:
Alex Crichton
2019-06-24 16:56:46 -07:00
committed by Ivan Petkov
parent 31c81faf96
commit 073a1a251a
2 changed files with 8 additions and 8 deletions
+4 -4
View File
@@ -8,7 +8,7 @@ use std::path::Path;
use std::process::{self, ExitStatus};
use futures::{Future, Poll};
use tokio_core::LoopHandle;
use tokio_core::reactor::Handle;
#[path = "unix.rs"]
#[cfg(unix)]
@@ -21,7 +21,7 @@ mod imp;
pub struct Command {
inner: process::Command,
#[allow(dead_code)]
handle: LoopHandle,
handle: Handle,
}
pub struct Spawn {
@@ -33,11 +33,11 @@ pub struct Child {
}
impl Command {
pub fn new<T: AsRef<OsStr>>(exe: T, handle: &LoopHandle) -> Command {
pub fn new<T: AsRef<OsStr>>(exe: T, handle: &Handle) -> Command {
Command::_new(exe.as_ref(), handle)
}
fn _new(exe: &OsStr, handle: &LoopHandle) -> Command {
fn _new(exe: &OsStr, handle: &Handle) -> Command {
Command {
inner: process::Command::new(exe),
handle: handle.clone(),
+4 -4
View File
@@ -7,7 +7,7 @@ use std::sync::mpsc::channel;
use std::sync::{Once, ONCE_INIT};
use std::thread;
use tokio_core::{Loop, LoopHandle};
use tokio_core::reactor::{Core, Handle};
use tokio_process::Command;
static INIT: Once = ONCE_INIT;
@@ -16,7 +16,7 @@ fn init() {
INIT.call_once(|| {
let (tx, rx) = channel();
thread::spawn(move || {
let mut lp = Loop::new().unwrap();
let mut lp = Core::new().unwrap();
let cmd = exit(&lp.handle());
let mut child = lp.run(cmd.spawn()).unwrap();
drop(child.kill());
@@ -28,7 +28,7 @@ fn init() {
});
}
fn exit(handle: &LoopHandle) -> Command {
fn exit(handle: &Handle) -> Command {
let mut me = env::current_exe().unwrap();
me.pop();
me.push("exit");
@@ -39,7 +39,7 @@ fn exit(handle: &LoopHandle) -> Command {
fn simple() {
init();
let mut lp = Loop::new().unwrap();
let mut lp = Core::new().unwrap();
let mut cmd = exit(&lp.handle());
cmd.arg("2");
let mut child = lp.run(cmd.spawn()).unwrap();