Struct Net 

pub struct Net { /* private fields */ }

Native relay handle (async tokio-tungstenite client).

Implementations

impl Net

pub async fn connect(url: &str) -> Result<Net, String>

pub async fn subscribe(&mut self, topic: &str) -> Result<(), String>

pub fn publish(&self, topic: &str, data: Vec<u8>) -> Result<(), String>

pub fn drain(&mut self) -> Vec<(String, Vec<u8>)>

Non-blocking: every message delivered since the last drain.