File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -20,6 +20,7 @@ byte-pool = "0.2.1"
20
20
lazy_static = " 1.4.0"
21
21
futures-core = " 0.3.1"
22
22
log = " 0.4"
23
+ async-channel = " 1.5.1"
23
24
24
25
[dev-dependencies ]
25
26
pretty_assertions = " 0.6.1"
Original file line number Diff line number Diff line change @@ -523,7 +523,7 @@ mod tests {
523
523
. as_bytes ( ) ,
524
524
) ;
525
525
526
- let ( s, _r) = async_std :: sync :: channel ( 1 ) ;
526
+ let ( s, _r) = async_channel :: bounded ( 1 ) ;
527
527
let sender = Sender :: new ( s) ;
528
528
let mut decoder = ChunkedDecoder :: new ( input, sender) ;
529
529
@@ -549,7 +549,7 @@ mod tests {
549
549
input. extend ( vec ! [ b'Z' ; 2048 ] ) ;
550
550
input. extend ( b"\r \n 0\r \n \r \n " ) ;
551
551
552
- let ( s, _r) = async_std :: sync :: channel ( 1 ) ;
552
+ let ( s, _r) = async_channel :: bounded ( 1 ) ;
553
553
let sender = Sender :: new ( s) ;
554
554
let mut decoder = ChunkedDecoder :: new ( async_std:: io:: Cursor :: new ( input) , sender) ;
555
555
@@ -579,7 +579,7 @@ mod tests {
579
579
\r \n "
580
580
. as_bytes ( ) ,
581
581
) ;
582
- let ( s, r) = async_std :: sync :: channel ( 1 ) ;
582
+ let ( s, r) = async_channel :: bounded ( 1 ) ;
583
583
let sender = Sender :: new ( s) ;
584
584
let mut decoder = ChunkedDecoder :: new ( input, sender) ;
585
585
You can’t perform that action at this time.
0 commit comments