File tree 1 file changed +3
-4
lines changed
1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -6,8 +6,6 @@ use std::{
6
6
} ,
7
7
} ;
8
8
9
- use async_task:: { Runnable , Task } ;
10
-
11
9
use crate :: { DroppableFuture , TaskIdentifier } ;
12
10
13
11
#[ derive( Debug ) ]
@@ -18,7 +16,8 @@ pub enum TaskState {
18
16
Drop ( TaskIdentifier ) ,
19
17
}
20
18
21
- type Payload = ( TaskIdentifier , Runnable ) ;
19
+ pub type Task < T > = async_task:: Task < T > ;
20
+ type Payload = ( TaskIdentifier , async_task:: Runnable ) ;
22
21
23
22
pub struct TickedAsyncExecutor < O > {
24
23
channel : ( mpsc:: Sender < Payload > , mpsc:: Receiver < Payload > ) ,
@@ -127,7 +126,7 @@ where
127
126
} )
128
127
}
129
128
130
- fn runnable_schedule_cb ( & self , identifier : TaskIdentifier ) -> impl Fn ( Runnable ) {
129
+ fn runnable_schedule_cb ( & self , identifier : TaskIdentifier ) -> impl Fn ( async_task :: Runnable ) {
131
130
let sender = self . channel . 0 . clone ( ) ;
132
131
let num_woken_tasks = self . num_woken_tasks . clone ( ) ;
133
132
let observer = self . observer . clone ( ) ;
You can’t perform that action at this time.
0 commit comments