calimero_network/handlers/commands/
subscribe.rs

1use actix::{Context, Handler, Message};
2use calimero_network_primitives::messages::Subscribe;
3
4use crate::NetworkManager;
5
6impl Handler<Subscribe> for NetworkManager {
7    type Result = <Subscribe as Message>::Result;
8
9    fn handle(&mut self, Subscribe(topic): Subscribe, _ctx: &mut Context<Self>) -> Self::Result {
10        let _ignored = self.swarm.behaviour_mut().gossipsub.subscribe(&topic)?;
11        Ok(topic)
12    }
13}

calimero_network/handlers/commands/subscribe.rs

calimero_network/handlers/commands/
subscribe.rs