#header #req #http #bumpalo #cookies

nightly ctx_

Extract message form headers only once for one req ( support async and sync ) / 一个请求只提取一次消息, 支持异步和同步

4 releases

new 0.1.4 Mar 4, 2025
0.1.3 Mar 4, 2025
0.1.2 Mar 4, 2025
0.1.1 Mar 4, 2025

#1619 in Network programming

Download history

59 downloads per month
Used in hpc

MulanPSL-2.0

67KB
1.5K SLoC

Rust 1K SLoC // 0.0% comments JavaScript 172 SLoC // 0.2% comments CoffeeScript 60 SLoC // 0.3% comments Shell 21 SLoC // 0.1% comments

ctx_

Use arena memory allocation bumpalo

Extract message form headers only once for one req ( support async / sync )

使用 arena 内存分配器 bumpalo

一个请求只提取一次消息, 支持异步 / 同步

use aok::{OK, Result};
use tokio::time::{Duration, sleep};
use ctx_::{Cookie, Ctx};
use http::{Method, Request};
use tracing::info;

#[static_init::constructor(0)]
extern "C" fn init() {
  loginit::init()
}

#[tokio::test]
async fn test() -> Result<()> {
  let request = Request::builder()
    .method(Method::POST)
    .uri("/my/path")
    .header("cookie", "session_id=12345; user_id=67890")
    .body(())?;

  let (request, _) = request.into_parts();

  {
    let req: Ctx = request.into();
    let req = &req;

    async {
      sleep(Duration::from_secs(2)).await;
      let cookie: &Cookie = ctx_::sync::get(req);
      info!("{}", cookie);
    }
    .await;

    async {
      sleep(Duration::from_secs(1)).await;
      let cookie: &Cookie = ctx_::sync::get(req);
      info!("{}", cookie);
    }
    .await;
  }
  info!("done");
  OK
}

About

This project is an open-source component of i18n.site ⋅ Internationalization Solution.

关于

本项目为 i18n.site ⋅ 国际化解决方案 的开源组件。

Dependencies

~5–17MB
~241K SLoC