File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
futures-util/src/stream/stream Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 1
- use crate :: stream:: Fuse ;
1
+ use crate :: stream:: { Fuse , StreamExt } ;
2
2
use alloc:: vec:: Vec ;
3
3
use core:: pin:: Pin ;
4
4
use futures_core:: stream:: { FusedStream , Stream } ;
@@ -22,7 +22,7 @@ impl<St: Stream> ReadyChunks<St> {
22
22
pub ( super ) fn new ( stream : St , capacity : usize ) -> Self {
23
23
assert ! ( capacity > 0 ) ;
24
24
25
- Self { stream : super :: Fuse :: new ( stream) , cap : capacity }
25
+ Self { stream : stream. fuse ( ) , cap : capacity }
26
26
}
27
27
28
28
delegate_access_inner ! ( stream, St , ( . ) ) ;
@@ -75,7 +75,7 @@ impl<St: Stream> Stream for ReadyChunks<St> {
75
75
}
76
76
}
77
77
78
- impl < St : FusedStream > FusedStream for ReadyChunks < St > {
78
+ impl < St : Stream > FusedStream for ReadyChunks < St > {
79
79
fn is_terminated ( & self ) -> bool {
80
80
self . stream . is_terminated ( )
81
81
}
You can’t perform that action at this time.
0 commit comments