meio-connect 0.97.0

Set of connectors for MEIO 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
26
27
28
29
30
31
32
33
34
35
36

//! The link to interact with a server instance.

use super::{
    route::{BoxedRoute, Route},
    HttpServer, HttpServerLink,
};
use anyhow::Error;
use async_trait::async_trait;
use meio::prelude::{Action, ActionHandler, Context};

impl HttpServerLink {
    /// Adds a route to the `HttpServer`.
    pub fn add_route<T>(&mut self, route: T) -> Result<(), Error>
    where
        T: Route,
    {
        let msg = AddRoute {
            route: Box::new(route),
        };
        self.address.act(msg)
    }
}

struct AddRoute {
    pub route: BoxedRoute,
}

impl Action for AddRoute {}

#[async_trait]
impl ActionHandler<AddRoute> for HttpServer {
    async fn handle(&mut self, msg: AddRoute, _ctx: &mut Context<Self>) -> Result<(), Error> {
        self.routing_table.insert_route(msg.route).await;
        Ok(())
    }
}