Function pamoja_mqtt_client_recv 

#[unsafe(no_mangle)]
pub unsafe extern "C" fn pamoja_mqtt_client_recv(
    client: *mut PamojaMqttClient,
    out_message: *mut *mut PamojaMqttMessage,
) -> PamojaStatus

Awaits the next message from any subscribed topic.

On success *out_message is set to a new message handle the caller owns and must release with pamoja_mqtt_message_free, or to null once the connection has ended and no further messages will arrive.

Returns

PamojaStatus::Ok on success (including end of stream), or an error status.

Safety

client must be a live handle from pamoja_mqtt_client_new and out_message must point to a writable *mut PamojaMqttMessage.