ockam_api 0.93.0

Ockam's request-response API
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use ockam::{Context, Result, Routed, Worker};

pub struct Uppercase;

#[ockam::worker]
impl Worker for Uppercase {
    type Message = String;
    type Context = Context;

    #[instrument(skip_all, name = "Uppercase::handle_message")]
    async fn handle_message(&mut self, ctx: &mut Context, msg: Routed<String>) -> Result<()> {
        let return_route = msg.return_route().clone();
        ctx.send(return_route.clone(), msg.into_body()?.to_uppercase())
            .await
    }
}