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.

pub fn buffered_len(&self) -> usize

Bytes the internal frame reader has buffered but not yet consumed.

Zero on a client that has issued no Self::request. A consumer that wants to take the raw socket back out via Self::into_stream checks this first: nonzero means there is response data the bare socket would not carry, so the take must be refused.

pub fn into_stream(self) -> Stream

Consume the client and return the underlying local-socket stream.

Hands the negotiated socket back to a consumer that will speak its own wire over it (see BrokerSession::into_backend_io). Any bytes still buffered by the frame reader are dropped, so callers must verify Self::buffered_len is zero before calling — which it always is on a freshly adopted session that has issued no request.