Struct RelayClient 

pub struct RelayClient { /* private fields */ }

A native relay client — and the reference for what the browser does over web-sys WebSocket with the same RelayFrame protocol.

Implementations

impl RelayClient

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

Dial a relay at url (ws://host:port).

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

Subscribe to topic and await the relay’s acknowledgement, so a subsequent publish from anyone cannot race ahead of the registration.

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

Publish data to topic.

pub async fn next_event(&mut self) -> Option<(String, Vec<u8>)>

Await the next event delivered for a subscribed topic.

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

Drain every event delivered so far WITHOUT blocking — the non-blocking “drain at a sync point” primitive the interpreter’s Sync uses.