pub fn reader_stream<Reader: Read + 'static>( reader_factory: Box<dyn ReaderFactory<Reader>>, file_path_stream: Pin<Box<dyn Stream<Item = Result<String, String>>>>, ) -> Pin<Box<dyn Stream<Item = Result<ReaderContext<Reader>, String>>>>