INNER CODE UNIT · Rust

send_qaul_messaging_message

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

    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,
        });
    }
}

impl NetworkBehaviour for QaulMessaging {
    type ConnectionHandler = OneShotHandler<QaulMessagingProtocol, QaulMessagingData, InnerMessage>;
    type ToSwarm = QaulMessagingEvent;

    fn on_connection_handler_event(

View source record →