3个不稳定版本

0.2.0 2021年8月21日
0.1.1 2021年8月6日
0.1.0 2021年8月4日

#258解析工具

Download history • Rust 包仓库 20/week @ 2024-03-04 • Rust 包仓库 22/week @ 2024-03-11 • Rust 包仓库 12/week @ 2024-03-18 • Rust 包仓库 16/week @ 2024-03-25 • Rust 包仓库 80/week @ 2024-04-01 • Rust 包仓库 10/week @ 2024-04-08 • Rust 包仓库 10/week @ 2024-04-15 • Rust 包仓库 16/week @ 2024-04-22 • Rust 包仓库 13/week @ 2024-04-29 • Rust 包仓库 107/week @ 2024-05-06 • Rust 包仓库 27/week @ 2024-05-13 • Rust 包仓库 77/week @ 2024-05-20 • Rust 包仓库 47/week @ 2024-05-27 • Rust 包仓库 24/week @ 2024-06-03 • Rust 包仓库 7/week @ 2024-06-10 • Rust 包仓库 18/week @ 2024-06-17 • Rust 包仓库

每月99次下载
用于 sie4

MIT 许可证

39KB
558

nom-bufreader,nom周围的BufReader适配器

*/!\进行中,如果将其用于生产,请修复/!*

使用此crate,您可以组装一个nom解析器,具有BufReader替代方案,同步或异步。由于不兼容的缓冲策略,无法直接使用std::io::BufReaderfutures::io::BufReader。此crate提供兼容的分支,位于bufreaderasync_bufreader模块中。

它将为您隐藏nom中流式解析器的Incomplete处理,自动重试和填充缓冲区。

示例

同步

use nom_bufreader::bufreader::BufReader;
use nom_bufreader::{Error, Parse};
use std::{net::TcpListener, str::from_utf8};

fn main() -> Result<(), Error<()>> {
    let listener = TcpListener::bind("127.0.0.1:8080")?;
    let mut i = BufReader::new(listener.incoming().next().unwrap()?);

    // method, space and path are nom parsers
    let m = i.parse(method)?;
    let _ = i.parse(space)?;
    let p = i.parse(path)?;
    println!("got method {}, path {}", m, p);
    Ok(())
}

异步

tokio

use nom_bufreader::async_bufreader::BufReader;
use nom_bufreader::{AsyncParse, Error};
use std::str::from_utf8;
use tokio_util::compat::TokioAsyncReadCompatExt;
use tokio::net::TcpListener;

#[tokio::main]
async fn main() -> Result<(), Error<()>> {
    let listener = TcpListener::bind("127.0.0.1:8080").await?;
    let mut i = BufReader::new(listener.accept().await?.0.compat());

    let m = i.parse(method).await?;
    let _ = i.parse(space).await?;
    let p = i.parse(path).await?;
    println!("got method {}, path {}", m, p);
    Ok(())
}

async-std

use nom_bufreader::async_bufreader::BufReader;
use nom_bufreader::{AsyncParse, Error};
use std::str::from_utf8;
use async_std::net::TcpListener;

#[async_std::main]
async fn main() -> Result<(), Error<()>> {
    let listener = TcpListener::bind("127.0.0.1:8080").await?;
    let mut i = BufReader::new(listener.accept().await?.0);

    let m = i.parse(method).await?;
    let _ = i.parse(space).await?;
    let p = i.parse(path).await?;
    println!("got method {}, path {}", m, p);
    Ok(())
}

依赖项

~0.9–1.3MB
~25K SLoC