Struct CffiSubscription 

pub struct CffiSubscription { /* private fields */ }

Subscription backed by a C vtable.

Implementations

impl CffiSubscription

pub fn topic_name(&self) -> &str

pub fn type_name(&self) -> &str

pub fn qos(&self) -> NrosRmwQos

pub fn can_loan_messages(&self) -> bool

true iff the backend exposes the receive loan primitive (Phase 99).

Trait Implementations

impl Drop for CffiSubscription

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.

impl Subscription for CffiSubscription

type Error = TransportError

Error type for receive operations

fn supports_process_in_place(&self) -> bool

Whether this backend implements the in-place dispatch methods (process_raw_in_place / process_raw_in_place_with_info) with a real zero-copy borrow.

fn process_raw_in_place( &mut self, f: impl FnOnce(&[u8]), ) -> Result<bool, Self::Error>

Process the received message in-place without copying.

fn has_data(&self) -> bool

Check if data is available without consuming it.

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

Try to receive one message into buf.

fn take_serialized_with_info( &mut self, buf: &mut [u8], ) -> Result<Option<(usize, Option<MessageInfo>)>, TransportError>

Try to receive raw data along with publisher metadata.

fn take_sequence( &mut self, buf: &mut [u8], per_msg_cap: usize, max_msgs: usize, out_lens: &mut [usize], ) -> Result<usize, TransportError>

Phase 124.D.1 — burst-take.

fn deserialization_error(&self) -> TransportError

Return a deserialization error (implementation specific)

fn unsupported_event_error(&self) -> TransportError

Phase 108 — backend’s error variant for “this event kind is not supported.” Default reuses deserialization_error() for backends that don’t have a distinct Unsupported mapping.

unsafe fn register_event_callback( &mut self, kind: EventKind, deadline_ms: u32, cb: EventCallback, user_ctx: *mut c_void, ) -> Result<(), TransportError>

Phase 108 — register a callback fired when the named status event occurs. deadline_ms applies to EventKind::RequestedDeadlineMissed only; ignored otherwise. Default impl returns the backend’s “unsupported”-shaped error.

fn take_serialized_with_attachment( &mut self, buf: &mut [u8], _att_buf: &mut [u8], ) -> Result<Option<(usize, usize)>, Self::Error>

Phase 128.F.4 — receive with attachment bytes alongside the payload.

fn take<M>(&mut self, buf: &mut [u8]) -> Result<Option<M>, Self::Error>

where M: RosMessage,

Try to receive a typed message (non-blocking)

fn process_raw_in_place_with_info( &mut self, f: impl FnOnce(&[u8], Option<MessageInfo>), ) -> Result<bool, Self::Error>

where Self::Error: From<TransportError>,

In-place processing variant that also surfaces publisher metadata.

fn register_waker(&self, _waker: &Waker)

Register an async waker to be notified when data arrives.

fn supports_event(&self, _kind: EventKind) -> bool

Phase 108 — true if the backend can generate this event for this subscriber. Default returns false; backends override per supported event kind.