|
1 | 1 | #[cfg(feature = "async")]
|
2 | 2 | use async_recursion::async_recursion;
|
3 | 3 | #[cfg(feature = "async")]
|
4 |
| -use futures::io::{AsyncRead, AsyncReadExt, AsyncSeekExt}; |
| 4 | +use futures::io::{AsyncReadExt, AsyncSeekExt}; |
5 | 5 | use std::collections::HashMap;
|
6 | 6 | use std::io::{Read, Result, Seek};
|
7 | 7 | use std::ops::RangeBounds;
|
@@ -112,7 +112,7 @@ pub fn read_directories(
|
112 | 112 | #[allow(clippy::module_name_repetitions)]
|
113 | 113 | #[cfg(feature = "async")]
|
114 | 114 | pub async fn read_directories_async(
|
115 |
| - reader: &mut (impl AsyncRead + Unpin + Send + AsyncReadExt + AsyncSeekExt), |
| 115 | + reader: &mut (impl Unpin + Send + AsyncReadExt + AsyncSeekExt), |
116 | 116 | compression: Compression,
|
117 | 117 | root_dir_offset_length: (u64, u64),
|
118 | 118 | leaf_dir_offset: u64,
|
@@ -145,9 +145,9 @@ fn range_end_inc(range: &impl RangeBounds<u64>) -> Option<u64> {
|
145 | 145 | }
|
146 | 146 |
|
147 | 147 | #[duplicate_item(
|
148 |
| - fn_name cfg_async_filter async add_await(code) seek_start(reader, offset) FilterRangeTraits input_traits read_directory(reader, len, compression); |
149 |
| - [read_dir_rec] [cfg(all())] [] [code] [reader.seek(std::io::SeekFrom::Start(offset))] [(impl RangeBounds<u64>)] [(impl Read + Seek)] [Directory::from_reader(reader, len, compression)]; |
150 |
| - [read_dir_rec_async] [cfg(feature="async")] [#[async_recursion] async] [code.await] [reader.seek(futures::io::SeekFrom::Start(offset)).await] [(impl RangeBounds<u64> + Sync + Send)] [(impl AsyncRead + Unpin + Send + AsyncReadExt + AsyncSeekExt)] [Directory::from_async_reader(reader, len, compression).await]; |
| 148 | + fn_name cfg_async_filter async add_await(code) seek_start(reader, offset) FilterRangeTraits input_traits read_directory(reader, len, compression); |
| 149 | + [read_dir_rec] [cfg(all())] [] [code] [reader.seek(std::io::SeekFrom::Start(offset))] [(impl RangeBounds<u64>)] [(impl Read + Seek)] [Directory::from_reader(reader, len, compression)]; |
| 150 | + [read_dir_rec_async] [cfg(feature="async")] [#[async_recursion] async] [code.await] [reader.seek(futures::io::SeekFrom::Start(offset)).await] [(impl RangeBounds<u64> + Sync + Send)] [(impl Unpin + Send + AsyncReadExt + AsyncSeekExt)] [Directory::from_async_reader(reader, len, compression).await]; |
151 | 151 | )]
|
152 | 152 | #[cfg_async_filter]
|
153 | 153 | async fn fn_name(
|
|
0 commit comments