@@ -9,7 +9,7 @@ fn test_tokio_join() {
9
9
let ( tx1, mut rx1) = tokio:: sync:: mpsc:: channel :: < usize > ( 1 ) ;
10
10
let ( tx2, mut rx2) = tokio:: sync:: mpsc:: channel :: < usize > ( 1 ) ;
11
11
executor
12
- . spawn ( "ThreadedFuture" , async move {
12
+ . spawn_local ( "ThreadedFuture" , async move {
13
13
let ( a, b) = tokio:: join!( rx1. recv( ) , rx2. recv( ) ) ;
14
14
assert_eq ! ( a. unwrap( ) , 10 ) ;
15
15
assert_eq ! ( b. unwrap( ) , 20 ) ;
@@ -19,7 +19,7 @@ fn test_tokio_join() {
19
19
let ( tx3, mut rx3) = tokio:: sync:: mpsc:: channel :: < usize > ( 1 ) ;
20
20
let ( tx4, mut rx4) = tokio:: sync:: mpsc:: channel :: < usize > ( 1 ) ;
21
21
executor
22
- . spawn ( "LocalFuture" , async move {
22
+ . spawn_local ( "LocalFuture" , async move {
23
23
let ( a, b) = tokio:: join!( rx3. recv( ) , rx4. recv( ) ) ;
24
24
assert_eq ! ( a. unwrap( ) , 10 ) ;
25
25
assert_eq ! ( b. unwrap( ) , 20 ) ;
@@ -46,7 +46,7 @@ fn test_tokio_select() {
46
46
let ( tx1, mut rx1) = tokio:: sync:: mpsc:: channel :: < usize > ( 1 ) ;
47
47
let ( _tx2, mut rx2) = tokio:: sync:: mpsc:: channel :: < usize > ( 1 ) ;
48
48
executor
49
- . spawn ( "ThreadedFuture" , async move {
49
+ . spawn_local ( "ThreadedFuture" , async move {
50
50
tokio:: select! {
51
51
data = rx1. recv( ) => {
52
52
assert_eq!( data. unwrap( ) , 10 ) ;
@@ -59,7 +59,7 @@ fn test_tokio_select() {
59
59
let ( tx3, mut rx3) = tokio:: sync:: mpsc:: channel :: < usize > ( 1 ) ;
60
60
let ( _tx4, mut rx4) = tokio:: sync:: mpsc:: channel :: < usize > ( 1 ) ;
61
61
executor
62
- . spawn ( "LocalFuture" , async move {
62
+ . spawn_local ( "LocalFuture" , async move {
63
63
tokio:: select! {
64
64
data = rx3. recv( ) => {
65
65
assert_eq!( data. unwrap( ) , 10 ) ;
0 commit comments