fxtools 0.2.39

A collection of commandline Fasta/Fastq utility tools
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use super::match_output_stream;
use anyhow::Result;
use fxread::{initialize_reader, initialize_stdin_reader};
use std::io::stdin;

pub fn run(
    input: Option<String>,
    output: Option<String>,
    num_records: usize,
    skip: usize,
    compression_threads: Option<usize>,
    compression_level: Option<usize>,
) -> Result<()> {
    let reader = if let Some(path) = input {
        initialize_reader(&path)
    } else {
        initialize_stdin_reader(stdin().lock())
    }?;
    let mut writer = match_output_stream(output, compression_threads, compression_level)?;

    let record_iter = reader.skip(skip).take(num_records);
    for record in record_iter {
        write!(writer, "{}", record.as_str(),)?;
    }
    Ok(())
}