tag ctrl_proto { find_reducer([u8], chan<int>); mapper_done; }
fn start_mappers(ctrl: chan<ctrl_proto>, inputs: [str]) {
- for i: str in inputs { task::spawn((ctrl, i), map_task); }
+ for i: str in inputs {
+ task::spawn {|| map_task(ctrl, i); };
+ }
}
- fn map_task(&&args: (chan<ctrl_proto>, str)) {
- let (ctrl, input) = args;
-
+ fn map_task(ctrl: chan<ctrl_proto>, input: str) {
let intermediates = map::new_str_hash();
fn emit(im: map::hashmap<str, int>, ctrl: chan<ctrl_proto>, key: str,