Struct DataLoader 

pub struct DataLoader<F> { /* private fields */ }

Data loader, to load data from files

Implementations

impl<F: DataFormatHandler> DataLoader<F>

pub fn new(dir: &Path) -> Result<Self>

Create a new data loader from a directory

pub fn load_file<T: Data>(&mut self, path: impl AsRef<Path>) -> DataReceiver<T>

Load Data from a file

pub fn load_map<M: DataMapper>( &mut self, path: impl AsRef<Path>, mapper: M, ) -> DataReceiver<M::Out>

Load and map data from a file

pub fn load_map_cached<M: DataMapper>( &mut self, path: impl AsRef<Path>, mapper: M, ) -> DataReceiver<M::Out>

where M::Out: Serialize + Data,

Load and map data from a file, but cache the result so the mapper is only invoked if the file has changed

pub fn load<Out: Send + 'static>( &mut self, path: &Path, f: impl FnOnce(&Path) -> Result<Out> + Send + 'static, ) -> DataReceiver<Out>

Loads data from a given path, with a custom Out type

pub fn load_all_files<T: Data, P: AsRef<Path>>( &mut self, paths: impl Iterator<Item = P>, ) -> DataReceiver<Vec<T>>

Load all files from a given iterator of paths

pub fn load_all_mapped<M: DataMapper + Clone, P: AsRef<Path>>( &mut self, paths: impl Iterator<Item = P>, mapper: M, ) -> DataReceiver<Vec<M::Out>>

Load all files from a given iterator of paths, with a custom mapper

pub fn load_all<Out: Send + 'static, P: AsRef<Path>>( &mut self, paths: impl Iterator<Item = P>, f: impl Fn(&Path) -> Result<Out> + Clone + Send + 'static, ) -> DataReceiver<Vec<Out>>

Load all files from a given iterator of paths, with a custom Out type

pub async fn wait_all(self) -> Result<()>

Wait for all pending tasks to finish and update the manifest