This is a library for making your flow function acting as a lambda service in flows.network.

Usage example

use lambda_flows::{request_received, send_response};

#[no_mangle]
#[tokio::main(flavor = "current_thread")]
pub async fn run() {
    request_received(handler).await;
}

async fn handler(_qry: HashMap<String, Value>, _body: Vec<u8>) {
    send_response(
        200,
        vec![(String::from("content-type"), String::from("text/html"))],
        "ok".as_bytes().to_vec(),
    );
}

When a request is received, the callback closure in request_received will be called. We get the query and body then set the status, headers and body of the response using send_response.

The whole document is here.