Struct FrameClient 

pub struct FrameClient { /* private fields */ }

Blocking request/response client for a backend daemon’s frame lane.

use running_process::broker::backend_sdk::FrameClient;
use running_process::broker::protocol::Endpoint;

let endpoint = Endpoint::unix_socket("my-daemon", "/tmp/my-daemon.sock")?;
let mut client = FrameClient::connect(&endpoint)?;
let response = client.request(0x7A63, b"ping".to_vec())?;
assert_eq!(response.payload, b"pong");

Implementations

impl FrameClient

pub fn connect(endpoint: &Endpoint) -> Result<Self, FrameClientError>

Connect to a backend endpoint using the platform local-socket name type (bare pipe name on Windows, filesystem path on Unix).

pub fn from_stream(stream: Stream) -> Self

Wrap an already-connected local-socket stream (e.g. one opened through a verified BackendHandle).

pub fn request( &mut self, payload_protocol: u32, payload: Vec<u8>, ) -> Result<Frame, FrameClientError>

Send one request frame and block until its response arrives.

Assigns the next request id, sends Frame::request(payload_protocol, payload), then reads frames until one echoes the id. The returned frame is validated to be a RESPONSE on the same payload protocol.

pub fn next_request_id(&self) -> u64

The request id the next Self::request call will use.