async fn handle_message(&mut self, ctx: &mut Context, msg: Routed<Any>) -> Result<()> {
        println!("Received: {}", msg);
        let mut msg = msg.into_transport_message();
        msg.onward_route.step()?;
        msg.return_route.modify().prepend(ctx.address());
        ctx.forward(msg).await
    }
/// This handle function takes any incoming message and forwards
/// it to the next hop in the route
This handle function takes any incoming message and forwards
it to the next hop in the route
This handle function takes any incoming message and forwards it to the next hop in the route
async fn handle_message(&mut self, ctx: &mut Context, msg: Routed<Any>) -> Result<()> {
        println!("Received: {}", msg);
        let mut msg = msg.into_transport_message();
        msg.onward_route.step()?;
        msg.return_route.modify().prepend(ctx.address());
        ctx.forward(msg).await
    }
async fn handle_message ( & mut self , ctx : & mut Context , msg : Routed < Any > ) -> Result < ( ) > { println ! ( " " msg ) ; let mut msg = msg . into_transport_message ( ) ; msg . onward_route . step ( ) ? ; msg . return_route . modify ( ) . prepend ( ctx . address ( ) ) ; ctx . forward ( msg ) . await }
This handle function takes any incoming message and forwards
it to the next hop in the route
This handle function takes any incoming message and forwards it to the next hop in the route
&mut self
ctx
&mut Context
msg
Routed<Any>
&mut self
ctx
&mut Context
msg
Routed<Any>