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
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use crate::session::ping::Ping;
use ockam::Worker;
use ockam_core::{Error, Routed};
use ockam_node::tokio::sync::mpsc;
use ockam_node::Context;

/// A collector receives echo messages and forwards them.
#[derive(Debug)]
pub(super) struct Collector(mpsc::Sender<Ping>);

impl Collector {
    pub fn new(sender: mpsc::Sender<Ping>) -> Self {
        Self(sender)
    }
}

#[ockam::worker]
impl Worker for Collector {
    type Message = Ping;
    type Context = Context;

    async fn handle_message(
        &mut self,
        _: &mut Context,
        msg: Routed<Self::Message>,
    ) -> Result<(), Error> {
        if self.0.send(msg.into_body()?).await.is_err() {
            debug!("collector could not send message to session")
        }
        Ok(())
    }
}