@@ -57,7 +57,7 @@ trait HomingIO {
57
57
let old_home = Cell :: new_empty ( ) ;
58
58
let old_home_ptr = & old_home;
59
59
do task:: unkillable { // FIXME(#8674)
60
- let scheduler = Local : : take :: < Scheduler > ( ) ;
60
+ let scheduler : ~ Scheduler = Local :: take ( ) ;
61
61
do scheduler. deschedule_running_task_and_then |_, task | {
62
62
// get the old home first
63
63
do task. wake ( ) . map_move |mut task| {
@@ -72,7 +72,7 @@ trait HomingIO {
72
72
73
73
// unhome home
74
74
do task:: unkillable { // FIXME(#8674)
75
- let scheduler = Local :: take :: < Scheduler > ( ) ;
75
+ let scheduler: ~ Scheduler = Local :: take ( ) ;
76
76
do scheduler. deschedule_running_task_and_then |scheduler, task| {
77
77
do task. wake( ) . map_move |mut task| {
78
78
task. give_home( old_home. take( ) ) ;
@@ -122,7 +122,7 @@ trait HomingIO {
122
122
123
123
// get a handle for the current scheduler
124
124
macro_rules! get_handle_to_current_scheduler(
125
- ( ) => ( do Local :: borrow:: < Scheduler , SchedHandle > |sched| { sched. make_handle( ) } )
125
+ ( ) => ( do Local :: borrow |sched: & mut Scheduler | { sched. make_handle( ) } )
126
126
)
127
127
128
128
enum SocketNameKind {
@@ -765,7 +765,7 @@ impl RtioTcpStream for UvTcpStream {
765
765
766
766
unsafe { ( * result_cell_ptr) . put_back ( result) ; }
767
767
768
- let scheduler: ~Scheduler = Local :: take :: < Scheduler > ( ) ;
768
+ let scheduler: ~Scheduler = Local :: take ( ) ;
769
769
scheduler. resume_blocked_task_immediately ( task_cell. take ( ) ) ;
770
770
}
771
771
}
0 commit comments