@@ -108,7 +108,7 @@ impl IoFactory for UvIoFactory {
108
108
assert ! ( scheduler. in_task_context( ) ) ;
109
109
110
110
// Block this task and take ownership, switch to scheduler context
111
- do scheduler. block_running_task_and_then |scheduler, task| {
111
+ do scheduler. deschedule_running_task_and_then |scheduler, task| {
112
112
113
113
rtdebug ! ( "connect: entered scheduler context" ) ;
114
114
assert ! ( !scheduler. in_task_context( ) ) ;
@@ -181,7 +181,7 @@ impl TcpListener for UvTcpListener {
181
181
do Scheduler :: local |scheduler| {
182
182
assert ! ( scheduler. in_task_context( ) ) ;
183
183
184
- do scheduler. block_running_task_and_then |_, task| {
184
+ do scheduler. deschedule_running_task_and_then |_, task| {
185
185
let task_cell = Cell ( task) ;
186
186
let mut server_tcp_watcher = server_tcp_watcher;
187
187
do server_tcp_watcher. listen |server_stream_watcher, status| {
@@ -247,7 +247,7 @@ impl Stream for UvStream {
247
247
assert ! ( scheduler. in_task_context( ) ) ;
248
248
let watcher = self . watcher ( ) ;
249
249
let buf_ptr: * & mut [ u8 ] = & buf;
250
- do scheduler. block_running_task_and_then |scheduler, task| {
250
+ do scheduler. deschedule_running_task_and_then |scheduler, task| {
251
251
rtdebug ! ( "read: entered scheduler context" ) ;
252
252
assert ! ( !scheduler. in_task_context( ) ) ;
253
253
let mut watcher = watcher;
@@ -293,7 +293,7 @@ impl Stream for UvStream {
293
293
assert ! ( scheduler. in_task_context( ) ) ;
294
294
let watcher = self . watcher ( ) ;
295
295
let buf_ptr: * & [ u8 ] = & buf;
296
- do scheduler. block_running_task_and_then |_, task| {
296
+ do scheduler. deschedule_running_task_and_then |_, task| {
297
297
let mut watcher = watcher;
298
298
let task_cell = Cell ( task) ;
299
299
let buf = unsafe { & * buf_ptr } ;
@@ -420,7 +420,7 @@ fn test_read_and_block() {
420
420
// Yield to the other task in hopes that it
421
421
// will trigger a read callback while we are
422
422
// not ready for it
423
- do scheduler. block_running_task_and_then |scheduler, task| {
423
+ do scheduler. deschedule_running_task_and_then |scheduler, task| {
424
424
scheduler. task_queue . push_back ( task) ;
425
425
}
426
426
}
0 commit comments