diff options
| -rw-r--r-- | src/librustdoc/markdown_writer.rs | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/src/librustdoc/markdown_writer.rs b/src/librustdoc/markdown_writer.rs index 3b9f07d6920..17d7774c7f5 100644 --- a/src/librustdoc/markdown_writer.rs +++ b/src/librustdoc/markdown_writer.rs @@ -26,6 +26,7 @@ use core::result; use core::run; use core::str; use core::task; +use core::pipes::*; use std::future; use syntax; @@ -168,12 +169,8 @@ fn readclose(fd: libc::c_int) -> ~str { } fn generic_writer(process: fn~(markdown: ~str)) -> Writer { - let (setup_po, setup_ch) = pipes::stream(); + let (po, ch) = stream::<WriteInstr>(); do task::spawn |move process, move setup_ch| { - let po: oldcomm::Port<WriteInstr> = oldcomm::Port(); - let ch = oldcomm::Chan(&po); - setup_ch.send(ch); - let mut markdown = ~""; let mut keep_going = true; while keep_going { @@ -184,10 +181,8 @@ fn generic_writer(process: fn~(markdown: ~str)) -> Writer { } process(move markdown); }; - let ch = setup_po.recv(); - fn~(instr: WriteInstr) { - oldcomm::send(ch, instr); + ch.send(instr); } } |
