Struct RpcWasmClient 

pub struct RpcWasmClient { /* private fields */ }

A WASM-compatible RPC client.

Implementations

impl RpcWasmClient

pub fn new( emit_callback: impl Fn(Vec<u8>) + Send + Sync + 'static, ) -> RpcWasmClient

pub async fn handle_connect(&self)

Call this from your JavaScript glue code when the WebSocket onopen event fires.

pub async fn read_bytes(&self, bytes: &[u8])

Call this from your JavaScript glue code when the WebSocket receives a message. This now handles both dispatcher reading and endpoint processing of incoming requests.

pub async fn handle_disconnect(&self)

Call this from your JavaScript glue code when the WebSocket’s onclose or onerror event fires.

pub fn is_connected(&self) -> bool

A helper method to check the connection status.

pub fn get_endpoint(&self) -> Arc<RpcServiceEndpoint<()>>

Trait Implementations

impl RpcServiceCallerInterface for RpcWasmClient

fn get_dispatcher(&self) -> Arc<Mutex<RpcDispatcher<'static>>>

fn get_emit_fn(&self) -> Arc<dyn Fn(Vec<u8>) + Send + Sync>

fn is_connected(&self) -> bool

fn set_state_change_handler<'life0, 'async_trait>( &'life0 self, handler: impl 'async_trait + Fn(RpcTransportState) + Send + Sync + 'static, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn call_rpc_streaming<'life0, 'async_trait>( &'life0 self, request: RpcRequest, dynamic_channel_type: DynamicChannelType, ) -> Pin<Box<dyn Future<Output = Result<(RpcStreamEncoder<Box<dyn RpcEmit<Output = ()> + Send + Sync>>, DynamicReceiver), RpcServiceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn call_rpc_buffered<'life0, 'async_trait, T, F>( &'life0 self, request: RpcRequest, decode: F, ) -> Pin<Box<dyn Future<Output = Result<(RpcStreamEncoder<Box<dyn RpcEmit<Output = ()> + Send + Sync>>, Result<T, RpcServiceError>), RpcServiceError>> + Send + 'async_trait>>

where 'life0: 'async_trait, T: Send + 'static + 'async_trait, F: Fn(&[u8]) -> T + Send + Sync + 'static + 'async_trait, Self: 'async_trait,