Struct RpcResponseHandler 

pub struct RpcResponseHandler {
    engine: Arc<WshRpcEngine>,
    req_id: String,
    source: String,
    canceled: AtomicBool,
    done: AtomicBool,
}

Allows an RPC handler to send responses back to the caller. Matches Go’s RpcResponseHandler.

Fields

engine: Arc<WshRpcEngine>

req_id: String

source: String

canceled: AtomicBool

done: AtomicBool

Implementations

impl RpcResponseHandler

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

Send a single response (or streaming chunk). Set done to true for the final response.

pub fn send_error(&self, err: &str)

Send an error response.

pub fn is_canceled(&self) -> bool

Check if the request has been canceled.

pub fn get_source(&self) -> &str

Get the source route ID of the request.

fn cancel(&self)

Mark this handler as canceled.

fn finalize(&self)

Finalize: send empty done response if not already done.