1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

mod multi;
#[allow(dead_code)]
mod read;
mod reader;
#[cfg(feature = "async")]
mod asynchronous;
#[cfg(feature = "async")]
pub use asynchronous::AsyncMultiReaders;
pub use reader::{BytesReader, SliceReader};
pub use multi::*;
/// Join multiple readers into a single
///
/// # Example
/// ```no_run
/// use multi_readers::{join_readers, BytesReader};
/// use std::fs::File;
///
/// let f = File::open("path").unwrap();
/// let bytes = vec![1, 2, 3, 4];
/// let br = BytesReader::new(bytes);
///
/// let mut reader = join_readers!(f, br);
/// ```
#[macro_export]
macro_rules! join_readers {
    ($($r:expr), +) => {
        $crate::MultiReaders::from_iter(vec![$(Box::new($r) as Box<dyn std::io::Read>, )+].into_iter())
    };
}

#[macro_export]
macro_rules! join_seek_readers {
    ($($r:expr), +) => {
        $crate::MultiSeekReaders::new(vec![$(Box::new($r) as Box<dyn $crate::SeekRead>, )+])
    };
}
#[macro_export]
macro_rules! join_paths_to_readers {
    ($($path:expr), +) => {
        {
            fn __open_file__() -> std::io::Result<Vec<Box<dyn std::io::Read>>> {
                Ok(vec![$(Box::new(std::fs::File::open($path)?) as Box<dyn std::io::Read>, )+])
            }
            __open_file__().map(|readers| {
                $crate::MultiReaders::from_iter(readers.into_iter())
            })
        }
    };
}

pub trait SeekRead: std::io::Read + std::io::Seek {
    
}
impl<T: std::io::Read + std::io::Seek> SeekRead for T {
    
}

#[cfg(feature = "async")]
/// Join multiple async readers into a single
#[macro_export]
macro_rules! join_async_readers {
    ($($r:expr), +) => {
        $crate::AsyncMultiReaders::from_iter(vec![$(Box::new($r) as Box<dyn tokio::io::AsyncRead + Unpin>, )+].into_iter())
    };
}