burger 0.1.0-rc.1

An experimental service framework.
Documentation 
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

use std::time::Duration;

use burger::{service_fn::service_fn, ServiceExt};
use futures_util::join;
use tokio::time::sleep;

#[tokio::main]
async fn main() {
    let svc = service_fn(|()| async {
        sleep(Duration::from_secs(1)).await;
        "foo "
    })
    .map(|output: &str| output.trim().to_string())
    .concurrency_limit(1)
    .buffer(2)
    .load_shed();

    let x = join! {
        svc.oneshot(()),
        svc.oneshot(()),
        svc.oneshot(()),
        svc.oneshot(()),
    };
    println!("{x:?}");
}