Method send

plugins/lsps-plugin/src/core/transport.rs:169–176

(&self, _peer: &PublicKey, _payload: &[u8])

    #[async_trait]
    impl MessageSender for MockSender {
        async fn send(&self, _peer: &PublicKey, _payload: &[u8]) -> Result<()> {
            self.call_count.fetch_add(1, Ordering::SeqCst);
            if self.should_fail {
                Err(Error::Internal("mock failure".into()))
            } else {
                Ok(())
            }
        }
    }

    #[tokio::test]