Struct Slow5WriteHandle 

pub struct Slow5WriteHandle { /* private fields */ }

Cloneable write handle for ParallelSlow5Writer.

Obtain one from ParallelSlow5Writer::write_handle and clone it for each rayon worker (or any thread). Calling write() compresses on the calling thread and enqueues the payload for the background I/O thread. Blocks under backpressure.

Drop all handles before calling ParallelSlow5Writer::finish.

Examples

use slow5lib::{Slow5WriteHandle, writer::ParallelSlow5Writer};
use slow5lib::header::{Header, RecordCompression, SignalCompression, ReadGroup};
use slow5lib::aux::AuxMeta;

let header = Header {
    version: (0, 2, 0),
    num_read_groups: 1,
    record_compression: RecordCompression::Zstd,
    signal_compression: SignalCompression::SvbZd,
    read_groups: vec![ReadGroup::default()],
    aux_meta: AuxMeta::default(),
};
let par_writer = ParallelSlow5Writer::create("out.blow5", header, 32)?;
let handle = par_writer.write_handle();
// handle.write(&rec)?;
drop(handle);
par_writer.finish()?;

Implementations

impl Slow5WriteHandle

pub fn write(&self, record: &Record) -> Result<()>

Encode and compress record on the calling thread, then enqueue for writing.

Blocks when the internal channel is full (backpressure from the I/O thread). Returns an error if the background writer thread has exited unexpectedly.

Trait Implementations

impl Clone for Slow5WriteHandle

fn clone(&self) -> Slow5WriteHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.