Struct seq_data_file::SeqDataWriter

pub struct SeqDataWriter<Format: SeqDataFormat> { /* private fields */ }

Writer for a new SeqData

Implementations

impl<Format: SeqDataFormat> SeqDataWriter<Format>

pub fn create<P: AsRef<Path>>(path: P, header: &[u8]) -> Result<Self>

Create a new SeqData File at the location specified

If the file already exists, this call will fail

The header need to fits the size of Format::HEADER_SIZE

Examples found in repository

examples/run.rs (line 41)

fn run_writer_reader<H: SeqDataFormat>(sdf_file: &Path) {
    {
        let header = vec![0x90; H::HEADER_SIZE];
        let mut sdf = SeqDataWriter::<H>::create(&sdf_file, &header).unwrap();
        sdf.append(DATA1).unwrap();
        sdf.append(DATA2).unwrap();
        sdf.append(DATA3).unwrap();
    }

    let mut pos = Vec::new();
    {
        let (mut sdf, _header) = SeqDataReader::<H>::open(&sdf_file).unwrap();
        let (p1, r1) = sdf.next().unwrap().unwrap();
        let (p2, r2) = sdf.next().unwrap().unwrap();
        let (p3, r3) = sdf.next().unwrap().unwrap();

        pos.push(p1);
        pos.push(p2);
        pos.push(p3);

        assert_eq!(p1, 0);
        assert_eq!(r1, DATA1);

        assert_eq!(p2, 4 + DATA1.len() as u64);
        assert_eq!(r2, DATA2);

        assert_eq!(p3, 4 * 2 + DATA1.len() as u64 + DATA2.len() as u64);
        assert_eq!(r3, DATA3);

        if let Some(x) = sdf.next() {
            panic!("more data than expected {:?}", x)
        }
    }

    {
        let (mut sdf, _header) = SeqDataReaderSeek::<H>::open(sdf_file).unwrap();
        let r2 = sdf.next_at(pos[1]).unwrap();
        assert_eq!(r2, DATA2);
        let r1 = sdf.next_at(pos[0]).unwrap();
        assert_eq!(r1, DATA1);
        let r3 = sdf.next_at(pos[2]).unwrap();
        assert_eq!(r3, DATA3);
    }
}

pub fn open<P: AsRef<Path>>(path: P, header: &[u8]) -> Result<(Self, Vec<u8>)>

Open a SeqData File at the location specified

If the file already exists, this call will fail

The header need to fits the size of Format::HEADER_SIZE

pub fn append(&mut self, data: &[u8]) -> Result<()>

Append a new data chunk to this file

Examples found in repository

examples/run.rs (line 42)

fn run_writer_reader<H: SeqDataFormat>(sdf_file: &Path) {
    {
        let header = vec![0x90; H::HEADER_SIZE];
        let mut sdf = SeqDataWriter::<H>::create(&sdf_file, &header).unwrap();
        sdf.append(DATA1).unwrap();
        sdf.append(DATA2).unwrap();
        sdf.append(DATA3).unwrap();
    }

    let mut pos = Vec::new();
    {
        let (mut sdf, _header) = SeqDataReader::<H>::open(&sdf_file).unwrap();
        let (p1, r1) = sdf.next().unwrap().unwrap();
        let (p2, r2) = sdf.next().unwrap().unwrap();
        let (p3, r3) = sdf.next().unwrap().unwrap();

        pos.push(p1);
        pos.push(p2);
        pos.push(p3);

        assert_eq!(p1, 0);
        assert_eq!(r1, DATA1);

        assert_eq!(p2, 4 + DATA1.len() as u64);
        assert_eq!(r2, DATA2);

        assert_eq!(p3, 4 * 2 + DATA1.len() as u64 + DATA2.len() as u64);
        assert_eq!(r3, DATA3);

        if let Some(x) = sdf.next() {
            panic!("more data than expected {:?}", x)
        }
    }

    {
        let (mut sdf, _header) = SeqDataReaderSeek::<H>::open(sdf_file).unwrap();
        let r2 = sdf.next_at(pos[1]).unwrap();
        assert_eq!(r2, DATA2);
        let r1 = sdf.next_at(pos[0]).unwrap();
        assert_eq!(r1, DATA1);
        let r3 = sdf.next_at(pos[2]).unwrap();
        assert_eq!(r3, DATA3);
    }
}