Struct WebsocketClient 

pub struct WebsocketClient<SE, PA>
where
    SE: StorageEngine + Send + Sync + 'static,
    PA: PolicyAgent + Send + Sync + 'static,
{ /* private fields */ }

A WebSocket client for connecting Ankurah nodes

Implementations

impl<SE, PA> WebsocketClient<SE, PA>

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,

pub async fn new(node: Node<SE, PA>, server_url: &str) -> Result<Self>

Create a new WebSocket client and start connecting to the server

pub fn state(&self) -> Read<ConnectionState>

Get the connection state as a reactive signal

pub fn is_connected(&self) -> bool

Check if currently connected to the server

pub async fn shutdown(self) -> Result<()>

Gracefully shutdown the WebSocket connection

pub async fn wait_connected(&self) -> Result<(), ConnectionError>

Wait for the client to establish a connection to the server (signal-based)

pub fn server_node_id(&self) -> Option<EntityId>

Get the node ID of the connected server (if connected)

Trait Implementations

impl<SE, PA> Drop for WebsocketClient<SE, PA>

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,

fn drop(&mut self)

Executes the destructor for this type.