#![allow(dead_code)]
-use memmap::Mmap;
+//use memmap::Mmap;
use crate::merger::Merger;
-use crate::reader::Reader;
+use crate::reader::FileReader;
use crate::Result;
use std::collections::HashMap;
use std::path::{Path, PathBuf};
fs_path: PathBuf,
last_reload: SystemTime,
reload_interval: Duration,
- readers: Mutex<HashMap<PathBuf, (Reader<Mmap>, SystemTime)>>,
+ readers: Mutex<HashMap<PathBuf, (FileReader, SystemTime)>>,
}
fn load_fs_file(f: impl AsRef<Path>) -> Result<Vec<PathBuf>> {
Ok(())
}
- pub fn readers(&mut self) -> Result<Vec<Reader<Mmap>>> {
+ pub fn readers(&mut self) -> Result<Vec<FileReader>> {
self.reload()?;
let readers = self.readers.lock().unwrap();
Ok(readers.iter().map(|(_, (r, _))| r.clone()).collect())
}
- pub fn merger(&mut self) -> Result<Merger<Reader<Mmap>>> {
+ pub fn merger(&mut self) -> Result<Merger<FileReader>> {
Ok(Merger::from(self.readers()?))
}
}