Struct RpcResponseHandler 

pub struct RpcResponseHandler {
    pub req_id: String,
    pub command: String,
    pub data: Option<Value>,
    pub rpc_context: RpcContext,
    response_tx: Sender<Vec<u8>>,
    finalized: AtomicBool,
}

Handler for incoming RPC requests (server side).

Fields

req_id: String

command: String

data: Option<Value>

rpc_context: RpcContext

response_tx: Sender<Vec<u8>>

finalized: AtomicBool

Implementations

impl RpcResponseHandler

pub fn get_command(&self) -> &str

Get the command name.

pub fn get_command_raw_data(&self) -> Option<&Value>

Get the raw command data.

pub fn get_rpc_context(&self) -> &RpcContext

Get the RPC context.

pub fn needs_response(&self) -> bool

Check if this request needs a response.

pub async fn send_response( &self, data: Option<Value>, done: bool, ) -> Result<(), String>

Send a response (data + done flag).

pub async fn send_response_error(&self, err: &str) -> Result<(), String>

Send an error response.

pub fn finalize(&self)

Mark the handler as finalized.

pub fn is_finalized(&self) -> bool

Check if the handler has been finalized.