INNER CODE UNIT · Rust

from_config

qaul/qaul.net · rust/libp2p_modules/qaul_messaging/src/lib.rs:41

    pub fn from_config(config: QaulMessagingConfig) -> Self {
        QaulMessaging {
            events: VecDeque::new(),
            config,
        }
    }

    /// Send a QaulMessagingMessage to a specific node
    pub fn send_qaul_messaging_message(&mut self, node_id: PeerId, data: Vec<u8>) {
        // create event message
        let message = QaulMessagingData { data };

        // Schedule message for sending
        self.events.push_back(ToSwarm::NotifyHandler {
            peer_id: node_id,
            handler: NotifyHandler::Any,
            event: message,
        });

View source record →