Skip to content

Commit fb096d7

Browse files
committed
---
yaml --- r: 13723 b: refs/heads/master c: d4672a0 h: refs/heads/master i: 13721: 3d89f90 13719: f1b3d4c v: v3
1 parent 8310bbf commit fb096d7

File tree

3 files changed

+10
-8
lines changed

3 files changed

+10
-8
lines changed

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
---
2-
refs/heads/master: ccd2394ff9ccff11950d0830aaeb74f4fabb7d9c
2+
refs/heads/master: d4672a078e62ca4c28e459fa541886b5b180cc9a
33
refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
44
refs/heads/snap-stage3: 4a81779abd786ff22d71434c6d9a5917ea4cdfff
55
refs/heads/try: 2898dcc5d97da9427ac367542382b6239d9c0bbf

trunk/src/libstd/net_tcp.rs

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ import ip = net_ip;
66
import uv::iotask;
77
import uv::iotask::iotask;
88
import comm::methods;
9+
import future_spawn = future::spawn;
910
import future::future;
1011
import result::{result,err,ok,extensions};
1112

@@ -248,9 +249,9 @@ A `future` value that, once the `write` operation completes, resolves to a
248249
value as the `err` variant
249250
"]
250251
fn write_future(sock: tcp_socket, raw_write_data: [u8]/~)
251-
-> future::future<result::result<(), tcp_err_data>> unsafe {
252+
-> future<result::result<(), tcp_err_data>> unsafe {
252253
let socket_data_ptr = ptr::addr_of(*(sock.socket_data));
253-
future::spawn {||
254+
future_spawn {||
254255
write_common_impl(socket_data_ptr, raw_write_data)
255256
}
256257
}
@@ -337,9 +338,9 @@ Otherwise, use the blocking `tcp::read` function instead.
337338
read attempt. Pass `0u` to wait indefinitely
338339
"]
339340
fn read_future(sock: tcp_socket, timeout_msecs: uint)
340-
-> future::future<result::result<[u8]/~,tcp_err_data>> {
341+
-> future<result::result<[u8]/~,tcp_err_data>> {
341342
let socket_data = ptr::addr_of(*(sock.socket_data));
342-
future::spawn {||
343+
future_spawn {||
343344
read_common_impl(socket_data, timeout_msecs)
344345
}
345346
}
@@ -802,15 +803,15 @@ impl sock_methods for tcp_socket {
802803
read(self, timeout_msecs)
803804
}
804805
fn read_future(timeout_msecs: uint) ->
805-
future::future<result::result<[u8]/~, tcp_err_data>> {
806+
future<result::result<[u8]/~, tcp_err_data>> {
806807
read_future(self, timeout_msecs)
807808
}
808809
fn write(raw_write_data: [u8]/~)
809810
-> result::result<(), tcp_err_data> {
810811
write(self, raw_write_data)
811812
}
812813
fn write_future(raw_write_data: [u8]/~)
813-
-> future::future<result::result<(), tcp_err_data>> {
814+
-> future<result::result<(), tcp_err_data>> {
814815
write_future(self, raw_write_data)
815816
}
816817
}

trunk/src/libstd/par.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ import comm::port;
22
import comm::chan;
33
import comm::send;
44
import comm::recv;
5+
import future_spawn = future::spawn;
56
import future::future;
67

78
export map, mapi, alli, any, mapi_factory;
@@ -42,7 +43,7 @@ fn map_slices<A: copy send, B: copy send>(
4243
// FIXME: why is the ::<A, ()> annotation required here? (#2617)
4344
vec::unpack_slice::<A, ()>(xs) {|p, _len|
4445
let f = f();
45-
let f = future::spawn() {|copy base|
46+
let f = future_spawn() {|copy base|
4647
unsafe {
4748
let len = end - base;
4849
let slice = (ptr::offset(p, base),

0 commit comments

Comments
 (0)