@@ -92,7 +92,7 @@ trait HomingIO {
9292 // go home
9393 let old_home = Cell : : new_empty ( ) ;
9494 let old_home_ptr = & old_home;
95- let scheduler = Local :: take :: < Scheduler > ( ) ;
95+ let scheduler: ~ Scheduler = Local :: take ( ) ;
9696 do scheduler. deschedule_running_task_and_then |_, task| {
9797 // get the old home first
9898 do task. wake ( ) . map_move |mut task| {
@@ -102,11 +102,11 @@ trait HomingIO {
102102 }
103103
104104 // do IO
105- let scheduler = Local :: take :: < Scheduler > ( ) ;
105+ let scheduler: ~ Scheduler = Local :: take ( ) ;
106106 let a = io_sched ( self , scheduler) ;
107107
108108 // unhome home
109- let scheduler = Local :: take :: < Scheduler > ( ) ;
109+ let scheduler: ~ Scheduler = Local :: take ( ) ;
110110 do scheduler. deschedule_running_task_and_then |scheduler, task| {
111111 do task. wake ( ) . map_move |mut task| {
112112 task. give_home ( old_home. take ( ) ) ;
@@ -442,7 +442,7 @@ impl IoFactory for UvIoFactory {
442442 do stream. close {
443443 let res = Err ( uv_error_to_io_error ( status. unwrap ( ) ) ) ;
444444 unsafe { ( * result_cell_ptr) . put_back ( res) ; }
445- let scheduler = Local :: take :: < Scheduler > ( ) ;
445+ let scheduler: ~ Scheduler = Local :: take ( ) ;
446446 scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
447447 }
448448 }
@@ -539,7 +539,7 @@ impl IoFactory for UvIoFactory {
539539 IoError > > = & result_cell;
540540 let path_cell = Cell :: new ( path) ;
541541 do task:: unkillable { // FIXME(#8674)
542- let scheduler = Local : : take :: < Scheduler > ( ) ;
542+ let scheduler : ~ Scheduler = Local :: take ( ) ;
543543 do scheduler. deschedule_running_task_and_then |_, task | {
544544 let task_cell = Cell :: new ( task) ;
545545 let path = path_cell. take ( ) ;
@@ -553,12 +553,12 @@ impl IoFactory for UvIoFactory {
553553 loop_, fd, true , home) as ~RtioFileStream ;
554554 let res = Ok ( fs) ;
555555 unsafe { ( * result_cell_ptr) . put_back ( res) ; }
556- let scheduler = Local :: take :: < Scheduler > ( ) ;
556+ let scheduler: ~ Scheduler = Local :: take ( ) ;
557557 scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
558558 } else {
559559 let res = Err ( uv_error_to_io_error ( err. unwrap ( ) ) ) ;
560560 unsafe { ( * result_cell_ptr) . put_back ( res) ; }
561- let scheduler = Local :: take :: < Scheduler > ( ) ;
561+ let scheduler: ~ Scheduler = Local :: take ( ) ;
562562 scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
563563 }
564564 } ;
@@ -573,7 +573,7 @@ impl IoFactory for UvIoFactory {
573573 let result_cell_ptr: * Cell < Result < ( ) , IoError > > = & result_cell;
574574 let path_cell = Cell :: new ( path) ;
575575 do task:: unkillable { // FIXME(#8674)
576- let scheduler = Local : : take :: < Scheduler > ( ) ;
576+ let scheduler : ~ Scheduler = Local :: take ( ) ;
577577 do scheduler. deschedule_running_task_and_then |_, task | {
578578 let task_cell = Cell :: new ( task) ;
579579 let path = path_cell. take ( ) ;
@@ -583,7 +583,7 @@ impl IoFactory for UvIoFactory {
583583 Some ( err) => Err ( uv_error_to_io_error ( err) )
584584 } ;
585585 unsafe { ( * result_cell_ptr) . put_back ( res) ; }
586- let scheduler = Local :: take :: < Scheduler > ( ) ;
586+ let scheduler: ~ Scheduler = Local :: take ( ) ;
587587 scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
588588 } ;
589589 } ;
@@ -1154,7 +1154,7 @@ impl UvFileStream {
11541154 Some ( err) => Err ( uv_error_to_io_error ( err) )
11551155 } ;
11561156 unsafe { ( * result_cell_ptr) . put_back ( res) ; }
1157- let scheduler = Local :: take :: < Scheduler > ( ) ;
1157+ let scheduler: ~ Scheduler = Local :: take ( ) ;
11581158 scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
11591159 } ;
11601160 } ;
@@ -1175,7 +1175,7 @@ impl UvFileStream {
11751175 Some ( err) => Err ( uv_error_to_io_error ( err) )
11761176 } ;
11771177 unsafe { ( * result_cell_ptr) . put_back ( res) ; }
1178- let scheduler = Local :: take :: < Scheduler > ( ) ;
1178+ let scheduler: ~ Scheduler = Local :: take ( ) ;
11791179 scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
11801180 } ;
11811181 } ;
@@ -1208,7 +1208,7 @@ impl Drop for UvFileStream {
12081208 do scheduler. deschedule_running_task_and_then |_, task| {
12091209 let task_cell = Cell :: new ( task) ;
12101210 do self_. fd . close ( & self . loop_ ) |_, _| {
1211- let scheduler = Local :: take :: < Scheduler > ( ) ;
1211+ let scheduler: ~ Scheduler = Local :: take ( ) ;
12121212 scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
12131213 } ;
12141214 } ;
@@ -1776,7 +1776,7 @@ fn file_test_uvio_full_simple_impl() {
17761776 use path:: Path ;
17771777 use rt:: io:: { Open , Create , ReadWrite , Read } ;
17781778 unsafe {
1779- let io = Local :: unsafe_borrow :: < IoFactoryObject > ( ) ;
1779+ let io: * mut IoFactoryObject = Local :: unsafe_borrow ( ) ;
17801780 let write_val = "hello uvio!" ;
17811781 let path = "./tmp/file_test_uvio_full.txt" ;
17821782 {
@@ -1810,7 +1810,7 @@ fn uvio_naive_print(input: &str) {
18101810 use str:: StrSlice ;
18111811 unsafe {
18121812 use libc:: { STDOUT_FILENO } ;
1813- let io = Local :: unsafe_borrow :: < IoFactoryObject > ( ) ;
1813+ let io: * mut IoFactoryObject = Local :: unsafe_borrow ( ) ;
18141814 {
18151815 let mut fd = ( * io) . fs_from_raw_fd ( STDOUT_FILENO , false ) ;
18161816 let write_buf = input. as_bytes ( ) ;
0 commit comments