Struct CffiServiceServer 

pub struct CffiServiceServer { /* private fields */ }

Service server backed by a C vtable.

Implementations

impl CffiServiceServer

pub fn service_name(&self) -> &str

pub fn type_name(&self) -> &str

Trait Implementations

impl Drop for CffiServiceServer

fn drop(&mut self)

Executes the destructor for this type.

impl ServiceServerTrait for CffiServiceServer

type Error = TransportError

Error type for service operations

fn has_request(&self) -> bool

Check if a request is available without consuming it.

fn try_recv_request<'a>( &mut self, buf: &'a mut [u8], ) -> Result<Option<ServiceRequest<'a>>, TransportError>

Try to receive a service request into buf (non-blocking).

fn send_reply( &mut self, sequence_number: i64, data: &[u8], ) -> Result<(), TransportError>

Send a reply for the given sequence number. Non-blocking from the application’s perspective; the backend may queue the reply for transport-level transmission.

fn register_waker(&self, _waker: &Waker)

Phase 122.3.c.6.e — register a Waker for event-driven service servers. Mirrors the matching method on SubscriberTrait / ServiceClientTrait. Backends that surface incoming-request notifications wake waker when has_request() flips true. Default: no-op (backends without wake support ignore — caller falls back to polling).

fn handle_request<S>( &mut self, req_buf: &mut [u8], reply_buf: &mut [u8], handler: impl FnOnce(&<S as RosService>::Request) -> <S as RosService>::Reply, ) -> Result<bool, Self::Error>

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

Handle a service request with typed messages

fn handle_request_boxed<S>( &mut self, req_buf: &mut [u8], reply_buf: &mut [u8], handler: impl FnOnce(&<S as RosService>::Request) -> Box<<S as RosService>::Reply>, ) -> Result<bool, Self::Error>

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

Handle a service request where the handler returns Box<S::Reply>