Struct WshRpcEngine 

pub struct WshRpcEngine {
    inner: Mutex<EngineInner>,
    output_tx: UnboundedSender<RpcMessage>,
}

Core RPC engine: handles incoming RPC requests, dispatches to registered command handlers, and manages request/response lifecycle.

Port of Go’s WshRpc from pkg/wshutil/wshrpc.go.

Fields

inner: Mutex<EngineInner>

output_tx: UnboundedSender<RpcMessage>

Implementations

impl WshRpcEngine

pub fn new() -> (Arc<Self>, UnboundedReceiver<RpcMessage>)

Create a new RPC engine. Returns the engine and a receiver for outgoing messages.

pub fn register_handler( &self, command: &str, handler: Box<dyn Fn(Value, RpcContext) -> Pin<Box<dyn Future<Output = Result<Option<Value>, String>> + Send>> + Send + Sync>, )

Register a call handler (single request → single response).

pub fn register_stream_handler( &self, command: &str, handler: Box<dyn Fn(Value, RpcContext) -> Pin<Box<dyn Future<Output = Result<Receiver<Result<Option<Value>, String>>, String>> + Send>> + Send + Sync>, )

Register a streaming handler (single request → stream of responses).

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

Set the authentication token.

pub fn get_auth_token(&self) -> String

Get the authentication token.

pub fn set_rpc_context(&self, ctx: RpcContext)

Set the RPC context.

pub fn handle_message(self: &Arc<Self>, msg: RpcMessage)

Process an incoming message (from the transport layer).

pub async fn send_command( self: &Arc<Self>, command: &str, data: Value, opts: &RpcOpts, ) -> Result<Value, String>

Send an RPC command and wait for a single response.

pub fn send_request( self: &Arc<Self>, command: &str, data: Value, opts: &RpcOpts, ) -> Result<RpcRequestHandler, String>

Send an RPC command and get a request handler for streaming responses.

pub fn send_command_no_response(&self, command: &str, data: Value, route: &str)

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

fn send_output(&self, msg: RpcMessage)

async fn handle_request(self: Arc<Self>, msg: RpcMessage)

fn handle_response(&self, msg: RpcMessage)

fn handle_cancel_request(&self, req_id: &str)

fn cleanup_handler(&self, req_id: &str)