Struct async_mavlink::AsyncMavConn

pub struct AsyncMavConn<M: Message> { /* fields omitted */ }

A async adapter for a MAVLink connection

Offers high level functionality to interact with a MAVLink vehicle in an async fashion.

Implementations

impl<M: 'static + Message + Clone + Send + Sync> AsyncMavConn<M>

pub fn new(
    address: &str
) -> Result<(Self, impl Future<Output = impl Send> + Send)>

Construct a new MavlinkConnectionHandler

Arguments

• address - MAVLink connection &str. Equivalent to the address argument in mavlink::connect

Examples

use async_mavlink::AsyncMavConn;
use mavlink::common::MavMessage;
use smol::prelude::*;

smol::block_on(async {
    let (conn, future) = AsyncMavConn::new("udpbcast:127.0.0.2:14551")?;
    smol::spawn(async move { future.await }).detach();
    // ...
})

pub async fn subscribe<'_>(
    &'_ self,
    message_type: MavMessageType<M>
) -> Pin<Box<dyn Stream<Item = M>>>

Subscribe to all new MavMessages of the given MavMessageType

This returns a never-ending Stream of MavMessages.

Arguments

• message_type - MavMessageType of the desired messages

Examples

use async_mavlink::{AsyncMavConn, MavMessageType};
use mavlink::common::MavMessage;

let message_type = MavMessageType::new(&MavMessage::PARAM_VALUE(Default::default()));
let mut stream = conn.subscribe(message_type).await;
while let Some(MavMessage::PARAM_VALUE(data)) = (stream.next()).await {
    // do something with `data`
}

pub async fn request<'_>(&'_ self, message_type: MavMessageType<M>) -> M

Awaits the next MavMessage of the given MavMessageType

Arguments

• message_type - MavMessageType of the desired messages

Examples

use async_mavlink::{AsyncMavConn, MavMessageType};
use mavlink::common::MavMessage;
                                                                                       
let message_type = MavMessageType::new(&MavMessage::PARAM_VALUE(Default::default()));

if let MavMessage::PARAM_VALUE(data) = conn.request(message_type).await {
    // do something with `data`
}

pub async fn send<'_, '_, '_>(
    &'_ self,
    header: &'_ MavHeader,
    message: &'_ M
) -> Result<()>

Send a MavMessage to the vehicle

Arguments

• message - MavMessage to send

Examples

use async_mavlink::MavMessageType;
use mavlink::{MavHeader, common::*};
                                                                                       
let header = MavHeader::default();
let message = MavMessage::PARAM_REQUEST_LIST(PARAM_REQUEST_LIST_DATA {
    target_component: 0,
    target_system: 0,
});

conn.send(&header, &message).await?;

pub async fn send_default<'_, '_>(&'_ self, message: &'_ M) -> Result<()>

Send a MavMessage to the vehicle

Arguments

• message - MavMessage to send

Examples

use mavlink::common::*;
                                                                                       
let message = MavMessage::PARAM_REQUEST_LIST(PARAM_REQUEST_LIST_DATA {
    target_component: 0,
    target_system: 0,
});

conn.send_default(&message).await?;

pub async fn last_heartbeat<'_>(&'_ self) -> Option<Instant>

Returns the Instant from the last received HEARTBEAT