Struct AsyncBlastXmlIter 

pub struct AsyncBlastXmlIter<R>
where
    R: AsyncBufRead + Unpin,
{ /* private fields */ }

Implementations

impl<R> AsyncBlastXmlIter<R>

where R: AsyncBufRead + Unpin,

pub fn from_reader(r: R) -> Self

Examples found in repository

examples/src/blast_parse.rs (line 37)

async fn main() -> Result<()> {
    let args = Cli::parse();
    let fmt = infer_format(&args.input, &args.format);
    let reader_box = open_async_reader(&args.input).await?;
    if fmt == "6" {
        stream_outfmt6_to_json(reader_box).await?;
    } else {
        // Build AsyncBlastXmlIter from reader_box
        let iter_reader = reader_box;
        let mut iter = AsyncBlastXmlIter::from_reader(iter_reader);
        while let Some(res) = iter.next_iteration().await {
            match res {
                Ok(iter_rec) => {
                    if args.json {
                        let mut buf = Vec::new();
                        serde_json::to_writer(&mut buf, &iter_rec)?;
                        buf.push(b'\n');
                        tokio::io::stdout().write_all(&buf).await?;
                    } else {
                        println!("query {:?} hits {}", iter_rec.query_def, iter_rec.hits.len());
                    }
                }
                Err(e) => eprintln!("xml parse error: {}", e),
            }
        }
    }

    Ok(())
}

pub async fn read_tag_content(&mut self, end_tag_name: &[u8]) -> Result<String>

Return the next iteration asynchronously (and none on EOF)

pub async fn next_iteration(&mut self) -> Option<Result<BlastXmlIteration>>

Examples found in repository

examples/src/blast_parse.rs (line 38)

async fn main() -> Result<()> {
    let args = Cli::parse();
    let fmt = infer_format(&args.input, &args.format);
    let reader_box = open_async_reader(&args.input).await?;
    if fmt == "6" {
        stream_outfmt6_to_json(reader_box).await?;
    } else {
        // Build AsyncBlastXmlIter from reader_box
        let iter_reader = reader_box;
        let mut iter = AsyncBlastXmlIter::from_reader(iter_reader);
        while let Some(res) = iter.next_iteration().await {
            match res {
                Ok(iter_rec) => {
                    if args.json {
                        let mut buf = Vec::new();
                        serde_json::to_writer(&mut buf, &iter_rec)?;
                        buf.push(b'\n');
                        tokio::io::stdout().write_all(&buf).await?;
                    } else {
                        println!("query {:?} hits {}", iter_rec.query_def, iter_rec.hits.len());
                    }
                }
                Err(e) => eprintln!("xml parse error: {}", e),
            }
        }
    }

    Ok(())
}