Struct WshRpc 

pub struct WshRpc {
    input_ch: Sender<Vec<u8>>,
    output_ch: Sender<Vec<u8>>,
    rpc_context: Arc<Mutex<Option<RpcContext>>>,
    auth_token: Arc<Mutex<String>>,
    rpc_map: Arc<Mutex<HashMap<String, RpcData>>>,
    event_listener: Arc<EventListener>,
    debug: AtomicBool,
    debug_name: String,
    server_done: AtomicBool,
}

Main WshRpc client.

Provides bidirectional RPC over message channels:

• Send requests and wait for responses
• Handle incoming requests with registered handlers
• Support streaming responses
• Auth token management

Fields

input_ch: Sender<Vec<u8>>

output_ch: Sender<Vec<u8>>

rpc_context: Arc<Mutex<Option<RpcContext>>>

auth_token: Arc<Mutex<String>>

rpc_map: Arc<Mutex<HashMap<String, RpcData>>>

event_listener: Arc<EventListener>

debug: AtomicBool

debug_name: String

server_done: AtomicBool

Implementations

impl WshRpc

pub fn new(debug_name: &str) -> (Self, Receiver<Vec<u8>>, Sender<Vec<u8>>)

Create a new WshRpc client with input/output channels.

pub fn set_rpc_context(&self, ctx: RpcContext)

Set the RPC context.

pub fn get_rpc_context(&self) -> Option<RpcContext>

Get the current RPC context.

pub fn set_auth_token(&self, token: &str)

Set the auth token.

pub fn get_auth_token(&self) -> String

Get the auth token.

pub fn set_debug(&self, debug: bool)

Enable or disable debug logging.

pub fn get_event_listener(&self) -> &EventListener

Get the event listener.

pub async fn send_rpc_request( &self, command: &str, data: Option<Value>, timeout_ms: Option<u64>, ) -> Result<Option<Value>, String>

Send an RPC request and wait for a single response.

pub async fn send_message( &self, command: &str, data: Option<Value>, ) -> Result<(), String>

Send a fire-and-forget message (no response expected).

pub fn process_incoming_message(&self, raw_msg: &[u8]) -> Result<(), String>

Process an incoming message (response or request).

fn handle_response(&self, msg: RpcMessage) -> Result<(), String>

Handle an incoming response message.

pub fn is_server_done(&self) -> bool

Check if the server is done.

pub fn set_server_done(&self)

Mark the server as done.

pub fn pending_count(&self) -> usize

Get the count of pending RPC requests.