1
1
//! Test suite for the Web and headless browsers.
2
2
3
3
#![ cfg( all( target_arch = "wasm32" , feature = "futures" ) ) ]
4
- use futures_rs:: prelude:: * ;
4
+
5
+ use futures_rs:: {
6
+ prelude:: * ,
7
+ sync:: { mpsc, oneshot} ,
8
+ } ;
5
9
use gloo_timers:: {
6
10
callback:: { Interval , Timeout } ,
7
11
future:: { IntervalStream , TimeoutFuture } ,
@@ -14,7 +18,7 @@ wasm_bindgen_test_configure!(run_in_browser);
14
18
15
19
#[ wasm_bindgen_test( async ) ]
16
20
fn timeout ( ) -> impl Future < Item = ( ) , Error = wasm_bindgen:: JsValue > {
17
- let ( sender, receiver) = futures :: sync :: oneshot:: channel ( ) ;
21
+ let ( sender, receiver) = oneshot:: channel ( ) ;
18
22
Timeout :: new ( 1 , || sender. send ( ( ) ) . unwrap ( ) ) . forget ( ) ;
19
23
receiver. map_err ( |e| e. to_string ( ) . into ( ) )
20
24
}
@@ -32,7 +36,7 @@ fn timeout_cancel() -> impl Future<Item = (), Error = wasm_bindgen::JsValue> {
32
36
} ) ;
33
37
t. cancel ( ) ;
34
38
35
- let ( sender, receiver) = futures :: sync :: oneshot:: channel ( ) ;
39
+ let ( sender, receiver) = oneshot:: channel ( ) ;
36
40
37
41
Timeout :: new ( 2 , move || {
38
42
sender. send ( ( ) ) . unwrap ( ) ;
@@ -86,7 +90,7 @@ fn timeout_future_cancel() -> impl Future<Item = (), Error = wasm_bindgen::JsVal
86
90
87
91
#[ wasm_bindgen_test( async ) ]
88
92
fn interval ( ) -> impl Future < Item = ( ) , Error = wasm_bindgen:: JsValue > {
89
- let ( mut sender, receiver) = futures :: sync :: mpsc:: channel ( 1 ) ;
93
+ let ( mut sender, receiver) = mpsc:: channel ( 1 ) ;
90
94
Interval :: new ( 1 , move || sender. try_send ( ( ) ) . unwrap ( ) ) . forget ( ) ;
91
95
receiver
92
96
. take ( 5 )
@@ -107,7 +111,7 @@ fn interval_cancel() -> impl Future<Item = (), Error = wasm_bindgen::JsValue> {
107
111
} ) ;
108
112
i. cancel ( ) ;
109
113
110
- let ( mut sender, receiver) = futures :: sync :: mpsc:: channel ( 1 ) ;
114
+ let ( mut sender, receiver) = mpsc:: channel ( 1 ) ;
111
115
Interval :: new ( 2 , move || {
112
116
sender. try_send ( ( ) ) . unwrap ( ) ;
113
117
assert_eq ! ( cell. get( ) , false ) ;
0 commit comments