fn build_pipe(&self, queue: LogQueue) -> Result<SinglePipe<F>> {
        let files = match queue {
            LogQueue::Append => &self.append_files,
            LogQueue::Rewrite => &self.rewrite_files,
        };
        let first_seq = files.first().map(|f| f.seq).unwrap_or(0);
        let files: VecDeque<FileHandler<F>> = files
            .iter()
            .map(|f| FileHandler {
                handle: f.handle.clone(),
                version: f.version.unwrap(),
            })
            .collect();
        SinglePipe::open(
            &self.cfg,
            self.file_system.clone(),
            self.listeners.clone(),
            queue,
            first_seq,
            files,
        )
    }
/// Builds a new storage for the specified log queue.
Builds a new storage for the specified log queue.
Builds a new storage for the specified log queue .
fn build_pipe(&self, queue: LogQueue) -> Result<SinglePipe<F>> {
        let files = match queue {
            LogQueue::Append => &self.append_files,
            LogQueue::Rewrite => &self.rewrite_files,
        };
        let first_seq = files.first().map(|f| f.seq).unwrap_or(0);
        let files: VecDeque<FileHandler<F>> = files
            .iter()
            .map(|f| FileHandler {
                handle: f.handle.clone(),
                version: f.version.unwrap(),
            })
            .collect();
        SinglePipe::open(
            &self.cfg,
            self.file_system.clone(),
            self.listeners.clone(),
            queue,
            first_seq,
            files,
        )
    }
fn build_pipe ( & self , queue : LogQueue ) -> Result < SinglePipe < F > > { let files = match queue { LogQueue :: Append => & self . append_files , LogQueue :: Rewrite => & self . rewrite_files , } ; let first_seq = files . first ( ) . map ( | f | f . seq ) . unwrap_or ( 0 ) ; let files : VecDeque < FileHandler < F > > = files . iter ( ) . map ( | f | FileHandler { handle : f . handle . clone ( ) , version : f . version . unwrap ( ) , } ) . collect ( ) ; SinglePipe :: open ( & self . cfg , self . file_system . clone ( ) , self . listeners . clone ( ) , queue , first_seq , files , ) }
Builds a new storage for the specified log queue.
Builds a new storage for the specified log queue .
&self
queue
LogQueue