Struct CffiClient 

pub struct CffiClient { /* private fields */ }

Service client backed by a C vtable.

Implementations

impl CffiClient

pub fn service_name(&self) -> &str

pub fn type_name(&self) -> &str

Trait Implementations

impl ClientTrait for CffiClient

fn request_publisher_actual_qos(&self) -> QoSProfile

What the REQUEST endpoint — the publisher this client sends requests on — was granted.

fn response_subscription_actual_qos(&self) -> QoSProfile

What the RESPONSE endpoint — the subscription this client takes replies on — was granted. See Self::request_publisher_actual_qos.

type Error = TransportError

Error type for service operations

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

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

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

Poll for a reply (non-blocking).

fn refused_response_len(&self) -> Option<usize>

Issue 1632 — how many bytes the reply the most recent take_response_raw REFUSED as too big for the caller’s buffer needed. Subscription::refused_sample_len’s contract, for the client: None is “the backend does not know”.

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

Whether a matching service server is currently discoverable.

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 take_response<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.

impl Drop for CffiClient

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.