layered 0.3.3

Build composable async services with layered middleware.
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
26
27
28

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

//! Basic service with middleware.
//!
//! Shows a simple service with intercept middleware for logging.

use layered::prelude::*;
use layered::{Execute, Intercept};

#[tokio::main]
async fn main() {
    let stack = (
        Intercept::layer()
            .on_input(|i| println!("on input: {i}"))
            .on_output(|o| println!("on output: {o}")),
        Execute::new(|input: String| async move {
            println!("executing input: {input}");
            input.to_uppercase()
        }),
    );

    // Build the service
    let service = stack.into_service();

    // Execute an input
    let _output = service.execute("Hello, World!".to_string()).await;
}