@@ -49,7 +49,7 @@ trait HomingIO {
49
49
// go home
50
50
let old_home = Cell :: new_empty ( ) ;
51
51
let old_home_ptr = & old_home;
52
- let scheduler = Local :: take :: < Scheduler > ( ) ;
52
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
53
53
do scheduler. deschedule_running_task_and_then |_, task| {
54
54
// get the old home first
55
55
do task. wake ( ) . map_move |mut task| {
@@ -62,7 +62,7 @@ trait HomingIO {
62
62
let a = io ( self ) ;
63
63
64
64
// unhome home
65
- let scheduler = Local :: take :: < Scheduler > ( ) ;
65
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
66
66
do scheduler. deschedule_running_task_and_then |scheduler, task| {
67
67
do task. wake ( ) . map_move |mut task| {
68
68
task. give_home ( old_home. take ( ) ) ;
@@ -77,7 +77,7 @@ trait HomingIO {
77
77
78
78
// get a handle for the current scheduler
79
79
macro_rules! get_handle_to_current_scheduler(
80
- ( ) => ( do Local :: borrow:: < Scheduler , SchedHandle > |sched| { sched. make_handle( ) } )
80
+ ( ) => ( do Local :: borrow |sched: & mut Scheduler | { sched. make_handle( ) } )
81
81
)
82
82
83
83
enum SocketNameKind {
@@ -632,7 +632,7 @@ impl RtioTcpStream for UvTcpStream {
632
632
633
633
unsafe { ( * result_cell_ptr) . put_back ( result) ; }
634
634
635
- let scheduler: ~Scheduler = Local :: take :: < Scheduler > ( ) ;
635
+ let scheduler: ~Scheduler = Local :: take ( ) ;
636
636
scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
637
637
}
638
638
}
0 commit comments