Skip to main content

pamoja_transport_recv

Function pamoja_transport_recv 

Source
#[unsafe(no_mangle)]
pub unsafe extern "C" fn pamoja_transport_recv( transport: *mut PamojaTransport, out_message: *mut *mut PamojaMessage, ) -> PamojaStatus
Expand description

Waits for the next message a transport delivers on a subscribed topic.

§Arguments

  • transport - the transport to receive from.
  • out_message - receives a message handle to release with pamoja_message_free, or null once the link has ended.

§Returns

PamojaStatus::Ok with a message or with null once the link has ended, or PamojaStatus::Closed if the transport is not connected.

§Safety

transport must be a live handle and out_message must be writable.