diff options
| author | bors <bors@rust-lang.org> | 2014-01-29 08:21:38 -0800 |
|---|---|---|
| committer | bors <bors@rust-lang.org> | 2014-01-29 08:21:38 -0800 |
| commit | e1580f6d09f0cd990c3eed55b1d6181af3258791 (patch) | |
| tree | 034b8287f1f017f7956d004be95184f53140bd5d /src/libnative | |
| parent | 87004db1137c9126ecc8834b1c881c2ef09ee8ef (diff) | |
| parent | a6867e259b98904d0144904b4ffbba61f7c8f6f9 (diff) | |
| download | rust-e1580f6d09f0cd990c3eed55b1d6181af3258791.tar.gz rust-e1580f6d09f0cd990c3eed55b1d6181af3258791.zip | |
auto merge of #11868 : bytbox/rust/remove-do, r=alexcrichton
Fixes #10815.
Diffstat (limited to 'src/libnative')
| -rw-r--r-- | src/libnative/io/timer_helper.rs | 4 | ||||
| -rw-r--r-- | src/libnative/task.rs | 32 |
2 files changed, 18 insertions, 18 deletions
diff --git a/src/libnative/io/timer_helper.rs b/src/libnative/io/timer_helper.rs index 3c20d073f29..9fc18220386 100644 --- a/src/libnative/io/timer_helper.rs +++ b/src/libnative/io/timer_helper.rs @@ -46,10 +46,10 @@ pub fn boot(helper: fn(imp::signal, Port<Req>)) { let (receive, send) = imp::new(); HELPER_SIGNAL = send; - do task::spawn { + task::spawn(proc() { bookkeeping::decrement(); helper(receive, msgp); - } + }); rt::at_exit(proc() { shutdown() }); }) diff --git a/src/libnative/task.rs b/src/libnative/task.rs index d2f68c4ef68..438ac4add39 100644 --- a/src/libnative/task.rs +++ b/src/libnative/task.rs @@ -272,19 +272,19 @@ mod tests { #[test] fn smoke() { let (p, c) = Chan::new(); - do spawn { + spawn(proc() { c.send(()); - } + }); p.recv(); } #[test] fn smoke_fail() { let (p, c) = Chan::<()>::new(); - do spawn { + spawn(proc() { let _c = c; fail!() - } + }); assert_eq!(p.recv_opt(), None); } @@ -311,38 +311,38 @@ mod tests { #[test] fn yield_test() { let (p, c) = Chan::new(); - do spawn { + spawn(proc() { 10.times(task::deschedule); c.send(()); - } + }); p.recv(); } #[test] fn spawn_children() { let (p, c) = Chan::new(); - do spawn { + spawn(proc() { let (p, c2) = Chan::new(); - do spawn { + spawn(proc() { let (p, c3) = Chan::new(); - do spawn { + spawn(proc() { c3.send(()); - } + }); p.recv(); c2.send(()); - } + }); p.recv(); c.send(()); - } + }); p.recv(); } #[test] fn spawn_inherits() { let (p, c) = Chan::new(); - do spawn { + spawn(proc() { let c = c; - do spawn { + spawn(proc() { let mut task: ~Task = Local::take(); match task.maybe_take_runtime::<Ops>() { Some(ops) => { @@ -352,8 +352,8 @@ mod tests { } Local::put(task); c.send(()); - } - } + }); + }); p.recv(); } } |
