Struct CffiServiceClient 

pub struct CffiServiceClient { /* private fields */ }

Service client backed by a C vtable.

Implementations

impl CffiServiceClient

pub fn service_name(&self) -> &str

pub fn type_name(&self) -> &str

Trait Implementations

impl Drop for CffiServiceClient

fn drop(&mut self)

Executes the destructor for this type.

impl ServiceClientTrait for CffiServiceClient

type Error = TransportError

Error type for service operations

fn call_raw( &mut self, request: &[u8], reply_buf: &mut [u8], ) -> Result<usize, TransportError>

👎Deprecated:

use Client::call → Promise::wait with an executor instead

Send a service request and wait for reply (blocking).

fn send_request_raw(&mut self, request: &[u8]) -> Result<(), TransportError>

Send a service request without waiting for a reply (non-blocking).

fn try_recv_reply_raw( &mut self, reply_buf: &mut [u8], ) -> Result<Option<usize>, TransportError>

Poll for a reply to the most recently sent request (non-blocking).

fn server_available(&self) -> Result<bool, TransportError>

Phase 124.C.1 — graph-aware server-availability probe.

fn send_request<S>( &mut self, request: &<S as RosService>::Request, req_buf: &mut [u8], ) -> Result<(), Self::Error>

where S: RosService, Self::Error: From<TransportError>,

Send a typed service request without waiting for a reply (non-blocking).

fn try_recv_reply<S>( &mut self, reply_buf: &mut [u8], ) -> Result<Option<<S as RosService>::Reply>, Self::Error>

where S: RosService, Self::Error: From<TransportError>,

Poll for a typed reply to the most recently sent request (non-blocking).

fn register_waker(&self, _waker: &Waker)

Register an async waker to be notified when a reply arrives.

fn start_server_discovery( &mut self, _timeout_ms: u32, ) -> Result<(), Self::Error>

Begin a server-discovery query on this client (non-blocking).

fn poll_server_discovery(&mut self) -> Result<Option<bool>, Self::Error>

Poll an in-flight server-discovery query.

fn is_server_ready(&self) -> bool

Synchronous, non-blocking check of whether a matching server is currently visible.

fn call<S>( &mut self, request: &<S as RosService>::Request, req_buf: &mut [u8], _reply_buf: &mut [u8], ) -> Result<<S as RosService>::Reply, Self::Error>

where S: RosService, Self::Error: From<TransportError>,

👎Deprecated:

use Client::call → Promise::wait with an executor instead

Call a service with typed messages (blocking).